我正在尝试使用 Java Thread 创建一个简单的队列,该队列允许一个循环,比如一个具有 10 次迭代的 for 循环,一次迭代 n (< 10) 个线程并等待这些线程完成后再继续迭代。
这里有一个更好的方法来说明我的问题:
for (int i = 1; i <= 10; i++) {
new Thread ( do_some_work() );
if ( no_available_threads ) {
wait_until_available_threads();
}
}
do_some_work() {
// do something that takes a long time
}
基本上我想做的是复制一份:Thread and Queue
我怎样才能以最轻松的方式实现这一目标?
最佳答案
我会使用 Java 5 Executors
而不是自己滚动。类似于以下内容:
ExecutorService service = Executors.newFixedThreadPool(10);
// now submit our jobs
service.submit(new Runnable() {
public void run() {
do_some_work();
}
});
// you can submit any number of jobs and the 10 threads will work on them
// in order
...
// when no more to submit, call shutdown, submitted jobs will continue to run
service.shutdown();
// now wait for the jobs to finish
service.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);
关于java - 使用 Java 线程创建一个简单的队列,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/9916264/