在循環中調用異步任務？

Question

我想在一個循環中調用一個異步任務並且並行執行幾次。

我有一個項目列表，我分成了更小的列表，每個列表中有10個項目。 然後，對於每個小型列表，我使用THREAD_POOL_EXECUTOR執行異步任務。

問題是，它不工作。我在想它，因爲每次傳遞給AsyncTask時都使用相同的列表 - 我認爲它可能作爲參考傳遞。

我是否需要以某種方式動態創建新列表？

//split the ListItems into 10s 
     if (actualThumbs.size() > 10){ 

     List<List<ListItem>> parts = chopped(actualThumbs, 10); // this splits it into parts of 10 
     List<ListItem> listToSend = new ArrayList<ListItem>(); //this is the list to pass 
    for(int i = 0; i < parts.size(); i++){ //for every part 


     for(int x = 0; x < parts.get(i).size(); x++){ //for everything in that part 
      //add to its own List 
      listToSend.add(parts.get(i).get(x)); 

     } 
     //this is the async task 
     loadActualThumbs thumbs = new loadActualThumbs(); 
     //execute multiple threads 
     thumbs.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR,listToSend); 
     listToSend.clear(); //clearing the list ready for a new one - PROBLEM? 
    } 
    } 
    else 
    { 
     //else just execute AsyncTask normally, this works OK 
     loadActualThumbs thumbs = new loadActualThumbs(); 
     thumbs.execute(actualThumbs); 
    } 

編輯：
我試圖改變我的代碼，而不是通過列出的清單中添加，我想發送到異步任務到另一個任務列表中的每個列表，然後循環和發送的每一個：

if (actualThumbs.size() > 10){ 

       List<List<ListItem>> parts = chopped(actualThumbs, 10); 
       List<ListItem> listToSend = new ArrayList<ListItem>(); 
       List<List<ListItem>> sendMe = new ArrayList<List<ListItem>>(); 
      for(int i = 0; i < parts.size(); i++){ //for every part 


       for(int x = 0; x < parts.get(i).size(); x++){ //for everything in that part 
        //add to its own ListItem? 
        listToSend.add(parts.get(i).get(x)); 

       } 

       sendMe.add(listToSend);// add the List to this List 
       listToSend.clear(); 
      } 

       for(int e = 0; e<sendMe.size();e++){ //loop through the list of lists 

        loadActualThumbs thumbs = new loadActualThumbs(); 
        //execute multiple threads? 
        thumbs.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR,sendMe.get(e)); // execute async with correct List 
       } 

      } 

      else 
      { 
       if (actualThumbs.size() > 0){ 
       //load actual thumbnails 
       loadActualThumbs thumbs = new loadActualThumbs(); 
       thumbs.execute(actualThumbs); 
       } 

      } 

Answer 1

你的代碼看起來應該是現在這個樣子！

List<List<ListItem>> parts = chopped(actualThumbs, 10); 
for(List<ListItem> list : parts) { 

    new loadActualThumbs().executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR, list); 

} 

我其實不知道線程池是什麼尺寸，或者如果它是一個緩存的線程池，但你可以用Executors.newCachedThreadPool（）和Executors.newFixedThreadPool（int count）創建你自己的線程池......但是我只想用AsyncTask.THREAD_POOL_EXECUTOR ....應該工作:)

Answer 2

如果你需要執行你的時間特定時間間隔的AsyncTask，那麼你可以利用定時器用於相同..

這樣的..

Timer timer = new Timer(); 
    TimerTask doAsynchronousTask = new TimerTask() { 
     @Override 
     public void run() { 
      try { 
       System.out 
         .println("=================== I am in pooling state ==============="); 
       GetBookingStatusAsyncTask performBackgroundTask = new GetBookingStatusAsyncTask(); 
       performBackgroundTask.execute(); 

      } catch (Exception e) { 
       e.printStackTrace(); 
      } 

     } 
    }; 

現在，當你需要殺死該定時器..

timer.cancel(); 
timer = null; 

還利用布爾檢查，以便avaoid無限循環..也就是說，如果爲true，則執行的AsyncTask ..如果爲假，則停止的AsyncTask ..只是想..

public void callAsynchronousTask(boolean b) { 

     // timer.cancel(); 
     if (b) { 

      System.out.println("============= Check for timer check " + tcheck); 
      // execute in every 10000 ms 
      tcheck++; 

     } else { 
      System.out 
        .println("============= Check for timer check + cancelling timer task " 
          + tcheck); 

      timer.cancel(); 
      timer = null; 
      System.out.println("=============timer is ===" + timer); 
      // finish(); 
      return; 
     } 

    } 

當您需要關閉此任務後來乾脆的真/假條件傳似..你需要通過這在您的AsyncTask。

callAsynchronousTask(true);/callAsynchronousTask(false); 

希望它可以幫助..