JavaスレッドプールでRejectedExecutionExceptionをスローするためのユニットテスト

Question

Javaスレッドプールを初めて使用しています。今私は新しいタスクが来て、現在のスレッド番号が最大数であり、キューがいっぱいであるときにユニットテストのユースケースを持っています。私はこの場合、RejectedExecutionExceptionが投げられることを知っています。しかし、どのように最高のこのシナリオを生成するために、私は今考えることができますが、このようなものです：

LinkedBlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>(1); 
ExecutorService ex = new ThreadPoolExecutor(2, 2, 60L, TimeUnit.MILLISECONDS, queue); 
int rejected = 0; 
try{ 
    while (true){ 
     ex.submit(() -> { 
      System.out.println("Queue remaining size: " + queue.remainingCapacity()); 
      System.out.println("Thread amount in pool: " + ((ThreadPoolExecutor)ex).getPoolSize() + "\n"); 
     }); 
    } 
} 
catch (RejectedExecutionException e){ 
    System.out.println(++rejected); 
} 

これが基本的な考えであり、私はそれが正しい方法である場合は、この使用してEasyMockを変換する必要があります。スレッドとキューがいっぱいになるまで、タスクを送信し続けるのではなく、EasyMockを使用する方が良い方法があるのだろうかと思います。

Answer 1

これが基本的な考えであり、私はそれが正しい方法である場合は、この使用してEasyMockを変換する必要があります。スレッドとキューがいっぱいになるまで、タスクを送信し続けるのではなく、EasyMockを使用する方が良い方法があるのだろうかと思います。

EasyMockが行うすべてのことは、匿名のコードよりも多くのコードを取得する可能性がありますRunnable。あなたは確かにそれを行うことができますが、Runnableの代わりにIAnswerオブジェクトを使用するので、はるかに良いとは思いません。

実際の質問は何をテストしているのですか？ ThreadPoolExecutorが仕事をしているか、実際にExecutorServiceを模倣しようとしているのか、@WarrenはThreadPoolExecutorと言っているのですか？

RunnableにThread.sleep(1000)を入れて、whileループの代わりに4個を送信します。最初に1つのオブジェクトを作成し、複数回送信することもできます。私はこれをサポート

BlockingQueue<Runnable> queue = new LinkedBlockingQueue<>(1); 
ExecutorService ex = new ThreadPoolExecutor(2, 2, 60L, TimeUnit.MILLISECONDS, queue); 
Runnable runnable = new Runnable() { 
    @Override 
    public void run() { 
     try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } 
    } 
}; 
try { 
    ex.submit(runnable); // 1st thread 
    ex.submit(runnable); // 2nd thread 
    ex.submit(runnable); // 1st queued 
    ex.submit(runnable); // rejected 
} catch (RejectedExecutionException e) { 
    System.out.println("rejected"); 
} 

Answer 2

私は特にEasyMockに精通していませんが、一般的なアプローチはThreadPoolExecutorをモックアウトすることです。

Answer 3

あなたは簡単に依存関係をモックすることができ、新しいクラスに実行コードを移動することがあります

class MyExecuter extends Executer{ 
    private final ExecuterService executerService; 
    private final PrintStream out; 
    MyExecuter(ExecutorService executerService, PrintStream out){ 
    this.executerService = executerService; 
    this.out = out; 
    } 
    @override 
    public void execute(Runnable r) { 
    int rejected = 0; 
    try{ 
     while (true) 
     { 
      executerService.submit(() -> { 
       // do your business logic which usually does not care about the executor or the queue... 
      }); 
     } 
    } 
    catch (RejectedExecutionException e) 
    { 
     out.println(++rejected); 
    } 

    } 
} 

あなたのコードは、これに変更します

LinkedBlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>(1); 
ExecutorService ex = new ThreadPoolExecutor(2, 2, 60L, TimeUnit.MILLISECONDS, queue); 
Executor mex = mew MyExcecutor(ex, System.out); 
mex.execute(); 

今あなたがテストを作成することができますMyExcecutorの場合はExecutorServiceとPrintStreamのモックを取得して、それらとのやり取りを確認できます。

Answer 4

一つの簡単な解決策：タスクを提出する前に

コールshutdown。

あなたはshutdown(後submit()を呼び出した場合）、あなたはexecptionのこのタイプを取得します：

java.util.concurrent.RejectedExecutionException: Task MyRunnable@3dcc0a0f 
rejected from java.util.concurrent.ThreadPoolExecutor