我正在寻找一种方法来限制线程数量，这些线程可以使用信号量或类似的方式在 Java 中运行某些代码部分。
我们正在研究类似于 Google Guava RateLimiter 的东西 - 但不是限制每秒调用次数，我们需要限制运行关键代码部分的线程数。
需要这个的原因是我们使用的某些库在这里有问题，所以我们只是在寻找一个快速的解决方法。
【问题讨论】：
标签： java multithreading concurrency
这正是java.util.concurrent.Semaphore 的设计初衷。你像这样创建一个Semaphore：
final int MAX_NOF_THREADS = 5;
final Semaphore mySemaphore = new Semaphore(MAX_NOF_THREADS);
那么对于你要做的关键区域：
try {
mySemaphore.aquire(); // This will hang until there is a vacancy
do_my_critical_stuff();
} finally {
mySemaphore.release();
}
...就这么简单。
【讨论】：
Semaphores，他们应该是这项任务的首选。不过，有一点值得一提：从技术上讲，一个线程可以进行多次获取。这意味着某些逻辑错误（例如，构思不当的递归）可能会导致线程未充分利用，甚至导致死锁。但如果小心使用，它们就是正确的工具。
不过，Semaphore 是这里的最佳选择（请查看@Bex 的回答），如果您小心的话，也可以使用ExecutorService。只需将您想要防止无限并发访问的代码包装到Callable 任务中，然后将此类任务提交给执行器服务：
// Task that will be executed
public class MyTask implements Callable<Void> {
@Override
public Void call() {
// Do the work here
return null;
}
}
// Service to execute tasks in no more than 5 parallel threads
// Cache it after creation and use when you need to execute a task
int maxThreadsCount = 5;
ExecutorService executor = Executors.newFixedThreadPool(maxThreadsCount);
// Execute a task. It will wait if all 5 threads are busy right now.
executor.submit(new MyTask());
使用ExecutorService，您还可以使用Runnable 代替Callable，invokeAll() 代替execute，等待任务完成，取消任务，从它们返回值并做一些其他有用的事情。
Java 8 让它变得更简单，您可以使用 lambdas 而不是定义任务类：
executor.submit(() -> {
// Do the work here
});
【讨论】：