Java中如何将类方法放入ThreadPoolExecutor执行？

一、先确认你的写法正确性 #

你实现Runnable包装类的方式是正确的，能正常把attach_point的逻辑放到线程池里执行。但缺点是重复写了一遍attach_point的核心代码，后续修改逻辑时要同时改两个地方，维护成本高。

二、更简洁的替代方式 #

1. 用Lambda表达式直接复用原方法 #

在ParallelPointSystem类内部，你可以直接用Lambda表达式捕获当前实例，提交任务时直接调用attach_point，完全不用单独写Attach_Point类：

// 假设你已初始化ThreadPoolExecutor实例executor
for (int i = 0; i < points.size(); i++) {
    final int index = i; // Java 8及之前需声明为final，Java 8+若为有效final可省略
    executor.submit(() -> {
        try {
            attach_point(index); // 直接调用当前类的私有方法
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    });
}

这种方式完全复用了原方法的逻辑，代码更简洁，也避免了重复维护的问题。

2. 使用Callable处理返回值/异常（可选） #

如果后续需要获取任务执行结果，或者更优雅地处理异常，可以用Callable替代Runnable：

for (int i = 0; i < points.size(); i++) {
    final int index = i;
    Future<Void> future = executor.submit(() -> {
        attach_point(index);
        return null;
    });
    // 后续可通过future.get()等待任务完成，或捕获ExecutionException处理异常
}

3. 匿名内部类（Lambda的旧版写法） #

这是Java 8之前的常规写法，现在基本被Lambda替代，仅作参考：

for (int i = 0; i < points.size(); i++) {
    final int index = i;
    executor.submit(new Runnable() {
        @Override
        public void run() {
            try {
                attach_point(index);
            } catch (Exception e) {
                throw new RuntimeException(e);
            }
        }
    });
}

三、关键注意点：线程安全 #

多个线程同时操作clusters中的Cluster对象（调用attach方法），必须确保：

• Cluster.attach()方法是线程安全的：如果attach会修改共享集合或状态，需要用synchronized同步，或者使用CopyOnWriteArrayList这类线程安全集合
• points和clusters集合本身在任务执行期间不能被修改（比如添加/删除元素）：ArrayList不是线程安全的，并发修改会引发异常

内容的提问来源于stack exchange，提问作者Andrey Gaponenko