Javaでコードの特定のセクションを実行するスレッドの数を制限する最良の方法は？

Question

私は、セマフォーなどを使用してJavaでコードの特定のセクションを実行できるスレッドの数を制限する方法を探しています。

Google Guava RateLimiterと似たようなものを探していましたが、1秒あたりの呼び出し数を制限する代わりに、コードのクリティカルセクションを実行するスレッド数を制限する必要があります。

私たちが使用している特定のライブラリには問題がありますので、すぐに回避策を探しています。

Answer 1

これは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(); 
} 

...そのような単純なよう。

Answer 2

注意しておけばSemaphoreが最適です（@ Bexの回答をご覧ください）。ExecutorServiceも使用できます。ちょうどあなたがCallableタスクに無制限の同時アクセスから保護し、エグゼキュータのサービスにこのようなタスクを提出したいコードの一部ラップ：ExecutorServiceで

// 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()); 

をあなたもRunnable代わりのCallable、invokeAll()の代わりに使用することができますexecute、タスクの完了を待って、タスクをキャンセルし、それらから値を返し、その他の便利なことをしてください。

のJava 8はそれを簡単になり、あなたの代わりにタスククラスを定義するラムダを使用することができます。

executor.submit(() -> { 
    // Do the work here 
});