スレッドごとに新しいCallableオブジェクトを作成する必要はありますか？ここ

Question

には2つのオプション

1）1コーラブル作成し、それを複数回

Callable<String> callable = new MyCallable(); 
     for(int i=0; i< 100; i++){ 
      Future<String> future = executor.submit(callable); 
      list.add(future); 
     } 

2を提出）各スレッド

for(int i=0; i< 100; i++){ 
     Future<String> future = executor.submit(new MyCallable()); 
     list.add(future); 
    } 

のベストプラクティスとは何であるため、複数の呼び出し可能オブジェクトを作成していますか？あなたのMyCallableあるスレッドセーフなクラスが、あなたはそれの同じインスタンスを再利用することができた場合は

Answer 1

、そうでない場合、あなたは競合状態と矛盾する結果となってしまいます。

つまり、MyCallableが正しく同期されていない状態を保持しようとすると、同じインスタンスを使用することはできません。あなたはAtomicIntegerでintを交換した場合のに対し

//Non-Thread Safe Callable implementation 
public class MyCallable implements Callable<String> { 

    private int i; 

    @Override 
    public String call() throws Exception { 
     i++; //RACE CONDITION 
     System.out.println(i); 
     return String.valueOf(i); 
    } 
} 

：たとえば

、MyCallableクラスの下に、あなたは、複数のスレッド（つまり、あなたはexecutor.submit(singleInstance)ようにそれを共有することはできません）間で同じインスタンスを再利用することはできません以下に示すように、あなたは同じインスタンスを再利用することができます

//Thread Safe Callable implementation 
public class MyThreadSafeCallable implements Callable<String> { 

    private AtomicInteger i = new AtomicInteger(0); 

    @Override 
    public String call() throws Exception { 
     int value = i.incrementAndGet(); 
     System.out.println(value); 
     return String.valueOf(value); 
    } 
} 

ので、ここで注意すべき重要な点は、あなたがCallable、Yの同じインスタンスを再利用したい場合は、ということですスレッドセーフであることを保証する必要があります。それ以外の場合は、に複数のCallableインスタンスを送信する必要があります。