Planer kwarcowy theadpool

Question

Klasa SimpleThreadPool dostarczana razem z Quartz Scheduler nie ma zachowania FIFO. Chcę się upewnić, że jeśli dodam nowe zadania do programu planującego, zostaną one zaadresowane na zasadzie First-in-First-out. Czy jest dostępny jakiś ThreadPool? Czy jest jakiś inny sposób, aby to osiągnąć?

Answer 1

Można to osiągnąć poprzez delegowanie do ThreadPoolExecutor z kolejki FIFO, co następuje:

public class DelegatingThreadPool implements ThreadPool { 

private int size = 5; //Fix this up if you like 
private final ThreadPoolExecutor executor = new ThreadPoolExecutor(size, size, 
            0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>()); 

public boolean runInThread(Runnable runnable) { 
    synchronized (executor) { 
     if (executor.getActiveCount() == size) { 
      return false; 
     } 
     executor.submit(runnable); 
     return true; 
    } 
} 

public int blockForAvailableThreads() { 
    synchronized (executor) { 
     return executor.getActiveCount(); 
    } 
} 

public void initialize() throws SchedulerConfigException { 
    //noop 
} 

public void shutdown(boolean waitForJobsToComplete) { 
    //No impl provided for wait, write one if you like 
    executor.shutdownNow(); 
} 

public int getPoolSize() { 
    return size; 
} 

public void setInstanceId(String schedInstId) { 
    //Do what you like here 
} 

public void setInstanceName(String schedName) { 
    //Do what you like here 
} 

Jest możliwe, że aktywny liczba wykonywalnych nie będzie dokładnie odpowiadać dokładną liczbę zadań, które realizują. Musisz dodać zatrzask i użyć funkcji beforeExecute, aby zapewnić, że zadanie zostało uruchomione, jeśli jest to konieczne.