Attività futura respinta da ThreadPoolExecutor

Question

Ho un ThreadPoolExecutor e invio un'attività a esso.

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

Questo codice sostiene la Runnable al ThreadPoolExecutor.

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); 
    } 
    } 

Il seguente codice arresta l'attività.

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

    threadPoolExecutor.shutdown(); 
} 

Il problema qui è: Quando provo a fermare l'operazione, io sono sempre seguente eccezione:

Task java.util.concurrent.FutureTask@3a475611 respinto da java.util.concurrent. ThreadPoolExecutor @ 216393fb [Terminato, dimensioni del pool = 0, thread attivi = 0, in coda tasks = 0, attività completate = 1]

Answer 1

il problema è che si shutdown() l'excutor nel metodo di arresto. Se si desidera solo attendere il completamento dell'attività, utilizzare Future.get(). Quando un esecutore viene spento, le attività non possono più essere inviate ad esso.

shutdown() deve essere utilizzato solo quando si desidera effettivamente terminare l'applicazione.