我該如何在此任務中只運行一次

Question

我的WebApplication中有下面這段代碼，基本上是這樣的，只要用戶登錄到應用程序中。

1. addSymbols方法將在用戶登錄操作期間被調用。
2. 由於上述原因，PriorityBlockingQueue被觸發
3. PriorityBlockingQueue將該符號添加到HashSet中，然後迭代該符號以在該新添加的符號上運行特定任務。

我在這裏面臨的問題是，作爲HashSet一部分的while循環一次又一次地執行相同的任務，因爲它處於線程的一個真正的條件內。

我粘貼示例輸出以瞭解與其相關的上下文。

Symbol From priorityBlocking SymbolTest 
Symbol From allSymbolsSet SymbolTest 
Symbol From allSymbolsSet SymbolTest 
Symbol From allSymbolsSet SymbolTest 
Symbol From allSymbolsSet SymbolTest 
Symbol From allSymbolsSet SymbolTest 
Symbol From allSymbolsSet SymbolTest 
Symbol From allSymbolsSet SymbolTest 
Symbol From allSymbolsSet SymbolTest 
Symbol From allSymbolsSet SymbolTest 
Symbol From allSymbolsSet SymbolTest 

這是我的代碼，它做了上述說明。

package com; 
import java.util.HashSet; 
import java.util.Iterator; 
import java.util.Set; 
import java.util.concurrent.ExecutorService; 
import java.util.concurrent.Executors; 
import java.util.concurrent.PriorityBlockingQueue; 

public class TaskerThread extends Thread { 
    private PriorityBlockingQueue<String> priorityBlocking = new PriorityBlockingQueue<String>(); 
    private Set<String> allSymbolsSet = new HashSet<String>(); 
    ExecutorService es = Executors.newFixedThreadPool(2); 

    public void addSymbols(String str) { 
     if (str != null) { 
      priorityBlocking.add(str); 
     } 
    } 

    public void run() { 
     while (true) { 
      try { 
       while (priorityBlocking.peek() != null) { 
        String symbol = priorityBlocking.poll(); 
        allSymbolsSet.add(symbol); 
        try { 
         System.out.println("Symbol From priorityBlocking" +" "+ symbol); 
        } catch (Exception e) { 
          e.printStackTrace(); 
        } 
       } 
       Iterator<String> ite = allSymbolsSet.iterator(); 
       while (ite.hasNext()) { 
        String symbol = ite.next(); 
        if (symbol != null && symbol.trim().length() > 0) { 
         try { 
          System.out.println("Symbol From allSymbolsSet"+" "+symbol); 
         } catch (Exception e) { 
          e.printStackTrace(); 
         } 
        } 
       } 
       Thread.sleep(2000); 
      } catch (Exception e) { 
       e.printStackTrace(); 
      } 
     } 
    } 
    public static void main(String args[]) { 
     try { 
      TaskerThread qT = new TaskerThread(); 
      qT.start(); 
      qT.addSymbols("SymbolTest"); 
     } catch (Exception e) { 
      e.printStackTrace(); 
     } 
    } 
} 

請讓我知道是否有任何方法可以讓Iterator任務只運行一次。

Answer 1

我明白了。發生了什麼事：

您的循環開始，並且符號被添加到隊列中。它從線程循環中的隊列中取出，然後運行迭代器循環。然後外層循環（while (true)）再次出現，這次沒有添加符號，但迭代器循環仍然執行。你需要的，如果一個新的符號已經被添加到只執行這個循環：

  boolean added = false; 
      while (priorityBlocking.peek() != null) { 
       added = true; 
       String symbol = priorityBlocking.poll(); 
       allSymbolsSet.add(symbol); 
       try { 
        System.out.println("Symbol From priorityBlocking" +" "+ symbol); 
       } catch (Exception e) { 
         e.printStackTrace(); 
       } 
      } 
      if (added) { 
       Iterator<String> ite = allSymbolsSet.iterator(); 
       while (ite.hasNext()) { 
        String symbol = ite.next(); 
        if (symbol != null && symbol.trim().length() > 0) { 
         try { 
          System.out.println("Symbol From allSymbolsSet"+" "+symbol); 
         } catch (Exception e) { 
          e.printStackTrace(); 
         } 
        } 
       } 
      } 

另外，使用take或poll(long,TimeUnit)也將停止你的循環，而你沒有什麼要補充的。這也應該避免循環的第二部分不必要地運行。你只需要處理InterruptedException。