将来のタスクはThreadPoolExecutorから拒否されました

Question

私はThreadPoolExecutorを持っており、タスクを提出しています。

private ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<Runnable>(1)); 

このコードはThreadPoolExecutorにRunnableを提出します。

protected void waitAndSweep(final String symbol) { 

    runnable = new Runnable() { 
     public void run() { /* irrelevant code */ } 
    }; 

    try { 
     Future<?> self = threadPoolExecutor.submit(runnable); 
     futures.add(self); 
    } catch (RejectedExecutionException re) { 
     /* this exception will be thrown when wait and sweep is called more than twice. 
     * threadPoolExecutor can have one running task and one waiting task. 
     */ 
    } catch (Exception e) { 
     logEvent(StrategyEntry.ERROR, "waitAndSweep", symbol, "Exception caught...", e); 
    } 
    } 

次のコードは、タスクを停止します。

ここ

protected synchronized void stop(StrategyEntry entry) throws Exception { 
    for (Object future : futures) { 
     ((Future<?>) future).cancel(true); 
    } 
    futures.clear(); 

    threadPoolExecutor.shutdown(); 
} 

問題がある：

タスクjava.util.concurrent.FutureTask@3a475611はjava.util.concurrentのから拒否：私はタスクを停止しようとすると、私は次の例外を取得しています。 ThreadPoolExecutor @ 216393fb [終端、プールサイズ= 0、アクティブなスレッド= 0、キューに入れられたタスク= 0、完了したタスクは= 1]

Answer 1

の問題は、あなたshutdown() stopメソッドでexcutor。タスクが完了するのを待つだけの場合は、Future.get()を使用します。エグゼキュータがシャットダウンされると、タスクはもう実行できなくなります。

shutdown()は、実際にアプリケーションを終了したい場合にのみ使用してください。