用Java线程创建一个简单的队列 [英] Create a simple queue with Java threads
本文介绍了用Java线程创建一个简单的队列的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
我正在尝试使用Java线程创建一个简单的队列,该队列将允许一个循环(例如,具有10次迭代的for循环)一次迭代n(<10)个线程,并等待直到这些线程完成后再继续进行迭代.
I'm trying to create a simple queue with Java Thread that would allow a loop, say a for loop with 10 iterations, to iterate n (< 10) threads at a time and wait until those threads are finished before continuing to iterate.
这是说明我的问题的更好方法:
Here's a better way to illustrate my problem:
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
}
基本上我想要做的是复制它:线程和队列
Basically what I want to do is a copy of this: Thread and Queue
我该如何最轻松地实现这一目标?
How can I achieve this the most painless way?
推荐答案
I would use the Java 5 Executors
instead of rolling your own. Something like the following:
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线程创建一个简单的队列的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!
查看全文