3

我有一个问题似乎与Executors 和 Thread 池所做的很接近，但我似乎无法让它完全适合。基本上我有一些工人需要一些时间来初始化并且我想集中起来，一旦他们准备好我就用它们来工作。我需要在 Thread 中执行此操作：

worker = buildExpensiveWorker();
worker.doWork(work1);
worker.doWork(work2);
worker.doWork(work3);
...

虽然 Executor 只允许我这样做：

doWork(work1);
doWork(work2);
doWork(work3);
...

我需要编写自己的线程池吗？重写已经做得很好的东西感觉很可惜。或者我需要用它ThreadLocal来持有我的工人，并从Runnable'run() 方法内部管理他们？

4

1 回答 1

5

如果您正在谈论在它们可用之前实际初始化 Thread 对象，请查看 ThreadPoolExecutor.setThreadFactory：

http://docs.oracle.com/javase/6/docs/api/java/util/concurrent/ThreadPoolExecutor.html#setThreadFactory(java.util.concurrent.ThreadFactory )

您可以提供自己的实现以任何您想要的方式创建线程，包括创建自定义线程子类和/或自定义初始化。

但是，我会说，如果您的初始化很昂贵，您可能应该尝试配置执行程序以尽可能长时间地保持实际线程处于活动状态（即，将保持活动时间设置得相当高，并尝试启动所有线程立即需要，并在前面受到打击）。

编辑：使用本地线程（如评论中所述）：

public class ThreadData {
    public static final ThreadLocal<String> data = new ThreadLocal<String>();
}

public class InitializingThread extends Thread {
    public InitializingThread(Runnable r) {
        super(r);
    }

    public void run() {
        ThreadData.data.set("foo");
        super.run();
    }
}

public class InitializingThreadFactory implements ThreadFactory {
    public Thread newThread(Runnable r) {
        return new InitializingThread(r);
    }
}

ThreadPoolExecutor executor = ...;
executor.setThreadFactory(new InitializingThreadFactory());
executor.execute(...);

然后在你的 Runnable 中：

public void run() {
     String s = ThreadData.data.get();
}

此外，这种方法（与使用 Thread.currentThread() 和强制转换相反）具有能够实际用于任何 Thread 实现（包括默认）或没有线程（直接调用 .run()在 ThreadLocal 中设置值后的方法）。您还可以轻松地将“ThreadLocal”更改为“InheritableThreadLocal”，并在将任何内容提交到线程池之前设置一次。所有子线程都将从其父线程（创建池的线程）继承该值。

重要的是要注意给定线程的“运行”方法只会执行一次，即使在线程池中也是如此，因此这可以保证您的初始化例程在每个线程的基础上发生。

于 2012-08-19T03:32:54.837 回答