ThreadPoolExecutor正在運行的應用程序

Question

賬單類具有與國家明智賬單相關的所有邏輯。它從數據庫中獲取結果，然後爲用戶開票。帳單類實現Runnable。我想根據國家參數並行執行結算，以便大量用戶（500萬+）非常快速地結算。現在需要數小時完成。

我想實現ThreadPoolExecutor執行Billing類，但很困惑如何？以下有什麼區別或者我做錯了什麼？請建議！區共有20個國家，但我在這裏粘貼僅5

//for 20 countries ThreadPoolExecutor (20,20,20.......)???? 

ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 5, 5, TimeUnit.SECONDS, 
new ArrayBlockingQueue<Runnable>(10), new ThreadPoolExecutor.CallerRunsPolicy()); 

executor.execute(new Billing("UK")); 
executor.execute(new Billing("USA")); 
executor.execute(new Billing("Germany")); 
executor.execute(new Billing("Spain")); 
executor.execute(new Billing("Italy")); 

OR

ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 5, 5, TimeUnit.SECONDS, 
new ArrayBlockingQueue<Runnable>(10), new ThreadPoolExecutor.CallerRunsPolicy()); 
for(int i=0;i<5;i++) // for 20 countries i<20?? 
{  

    executor.execute(new Billing("UK")); 
    executor.execute(new Billing("USA")); 
    executor.execute(new Billing("Germany")); 
    executor.execute(new Billing("Spain")); 
    executor.execute(new Billing("Italy")); 
} 

while (! executor.isTerminated()) { 
    try{ 
     executor.awaitTermination(100, TimeUnit.SECONDS); 
    }catch(InterruptedException iE) 
    { 
     iE.printStackTrace(); 
     System.out.println("Executor Exception: "+ iE); 
    } 

在此先感謝！

Answer 1

循環解決方案看起來不正確。不需要多次執行相同的Runnable。

你既corePoolSize和maximumPoolSize設置爲5，這意味着執行程序將保持線程的數量在游泳池5，即使它們是空閒實例ThreadPoolExecutor。它還說池中的線程數不能超過5。

在此位置，您可以預計至多5線程正在並行執行任務（Billing對象）。

隨着您繼續提交Billing對象到executor與execute方法它們被添加到您提供的ArrayBlockingQueue。此隊列的大小爲10。在某些情況下，隊列中的隊列可能已經處於最大容量並且不能承擔更多任務，在這種情況下，任務將被拒絕並提供給ThreadPoolExecutor構造函數中提供的RejectedExecutionHandler。它的工作是用已實施的方法rejectedExecution處理被拒絕的任務。

如果你想找到是否有任何被拒絕的任務，你必須提供自己的RejectedExecutionHandler而不是使用默認的ThreadPoolExecutor.CallerRunsPolicy。你可以像這樣做：

ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 5, 5, 
     TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(10), 
     new RejectedExecutionHandler() { 
      @Override 
      public void rejectedExecution(Runnable r, 
        ThreadPoolExecutor executor) { 
       System.out.println("I got rejected: " + r); 
       if (!executor.isShutdown()) { 
        r.run(); 
       } 
      } 
     }); 

Answer 2

我不確定你瞭解循環如何工作。不同之處在於第二個代碼塊將在每個列出的國家/地區運行計費5次。

Answer 3

假設你正在談論的代碼for環部分並不明顯，將如何工作。

理想的循環將是這個樣子：

for(String country : countryCollection) { 
    executor.execute(new Billing(country)); 
} 

Answer 4

你有沒有考慮使用enum？

static class Billing implements Runnable { 

    enum Country { 
    UK, 
    USA, 
    Germany, 
    Spain, 
    Italy; 
    } 

    public Billing(Country country) { 
    } 

    @Override 
    public void run() { 
    } 
} 
public void test() { 
    ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 5, 5, TimeUnit.SECONDS, 
     new ArrayBlockingQueue<Runnable>(10), 
      new ThreadPoolExecutor.CallerRunsPolicy()); 
    for (Billing.Country country : Billing.Country.values()) { 
    executor.execute(new Billing(country)); 
    } 
} 

Answer 5

第一：忘記循環

for(int i=0;i<5;i++) // for 20 countries i<20?? 
{  

    executor.execute(new Billing("UK")); 
    executor.execute(new Billing("USA")); 
    executor.execute(new Billing("Germany")); 
    executor.execute(new Billing("Spain")); 
    executor.execute(new Billing("Italy")); 
} 

這一切賬單多次遍歷。

做的正確的事情是在第一個片段：

executor.execute(new Billing("UK")); 
executor.execute(new Billing("USA")); 
executor.execute(new Billing("Germany")); 
executor.execute(new Billing("Spain")); 
executor.execute(new Billing("Italy")); 

另一個錯誤在於對終端的檢查：

while (! executor.isTerminated()) { 
    try{ 
     executor.awaitTermination(100, TimeUnit.SECONDS); 
    }catch(InterruptedException iE) 
    { 
     iE.printStackTrace(); 
     System.out.println("Executor Exception: "+ iE); 
    } 
} 

的Executor.awaitTermination的Javadoc說：

塊直到所有任務在關閉請求後完成執行，

但您永遠不會發出關閉請求。

在你的情況，你可以充分利用ExecutorCompletionService爲：

CompletionService<String> ecs = new ExecutorCompletionService<String>(executor); 
List<String> countries= Arrays.asList("UK","USA","Germany","Spain","Italy"); 
for(String country : countries) { 
    ecs.submit(new Billing(country),country); 
} 
// wait for completion 
for(int i=0;i<countries.size();i++){ 
     ecs.take(); // wait for next country completion 
} 
// all work completed, shutdown 
executor.shutdownNow(); 

Answer 6

另一種方式來思考實現這個就是看看The Fork/Join Framework。這看起來似乎可以真正從鍊鋼獲益。例如，你可以看起來相當乾淨地分解它。這基本上可以讓您打破用戶或部分用戶的計費任務，而不是讓一個看起來代表一個國家的線程在整個計費過程中工作。

你可以找到的鏈接庫：here if you are using a version of Java < 7