限制线程数和Java并发

Question

我找不到使用最新JAVA并发例程的这种特定情况的示例.

我打算用来threads处理开放队列中的项目,这些项目可能包含0到数千个请求.我想限制所以在任何给定时间,不少于0并且不超过10个线程处理队列项.

是否有针对此特定类型案例的Java并发流程？

Answer 1

我认为线程池是您正在寻找的.看看ExecutorService和Executors.

ExecutorService:http://docs.oracle.com/javase/6/docs/api/java/util/concurrent/ExecutorService.html

执行人:http://docs.oracle.com/javase/6/docs/api/java/util/concurrent/Executors.html

获取一个处理最大值的新线程固定线程池.10个线程:

ExecutorService threadPool = Executors.newFixedThreadPool(10);

使用提交方法,您可以将Callables或Runnables传递给池.

对于您的用例,您需要一个查看Queue的进程,如果有新请求,则必须创建Callable或Runnable并将其传递给线程池.游泳池确保最大化 一次执行10个线程.

这是一个非常小的教程:http://www.math.uni-hamburg.de/doc/java/tutorial/essential/threads/group.html

使用线程池的一个好处是submit方法返回一个Future对象,它支持执行线程的返回类型.

未来:http://docs.oracle.com/javase/6/docs/api/java/util/concurrent/Future.html

我希望这可以帮助您解决问题.