executors

    2熱度

    2回答

    我正在設計一個安卓應用程序,它會監聽傳入的短信,並以特定方式處理它們。 我有一個接收郵件,並將其發送給一個意圖服務的廣播接收機: Intent serviceIntent = new Intent(context, SMSIntentService.class); serviceIntent.putExtras(intent.getExtras()); context.startService

    0熱度

    2回答

    請不要把下面的問題看作是重複的問題..! 我開發了一個讓多線程按順序依次運行的類。這個類的claimAccess函數和release Access函數之間的所有應用程序代碼一次只能在一個線程中執行。所有其他線程將在隊列中等待,直到前一個線程完成。現在請告知可以同樣的事情由像執行人,循環障礙或倒計時鎖也有一些其他的方式來實現.. !!請建議如何能夠通過其他途徑建立 import java.util.

    1熱度

    1回答

    在netty中,如何從websocket服務器週期性地(例如每n秒)持續推送一些數據,最好的方法是什麼? 編輯: 我遇到了這個帖子:Best way to send continuous data in Java using Netty並根據答案,而/睡眠不會是很可擴展性,如何做一個時間表上的執行器工作?

    0熱度

    1回答

    對於我的程序,我使用ConcurrentHashMap來保存對多個運行對象的引用。 在我的服務器我有: public class Server { private ConcurrentHashMap<String, ChatRoom> _chatRooms; private ExecutorService _chatRoomExecutor; ... // create a new c

    9熱度

    3回答

    我有一項任務,要求我安排任務並在發生某些事件時將其刪除。我使用ScheduledThreadPoolExecutor來安排任務,這非常簡單。但是,我發現了兩種取消待處理項目的方法,它們都顯得有些古怪。 我很好奇,如果他們中的任何一個在生產質量。如果他們都不是,那麼你有什麼建議? 這裏是我做的一個骨架: private final ScheduledThreadPoolExecutor schedu

    0熱度

    1回答

    我有一個Swing應用程序,它使用ThreadPoolExecutor執行多個任務。有一次,我想重新初始化一切。我正在使用executor.purge();和executor.getQueue().clear();這夠了嗎?有沒有更好的方法/做法來執行此操作?提前致謝。

    1熱度

    4回答

    任何人都可以使用有關爲什麼我們應該使用線程池的示例進行解釋。 從理論上講,我已經知道使用帶有Executors的線程池了。 我已經通過教程的數量了,但我沒有得到有關我們爲什麼要使用線程池任何實際的例子,它可以是的newFixedThreadPool或newCachedThreadPool或newSingleThreadExecutor 在可擴展性和性能方面。 如果有人解釋我關於性能和可伸縮性的例子

    5熱度

    3回答

    我有一系列的任務(即Runnable s)由Executor執行。 每個任務都需要一定的條件才能繼續。我想知道是否有辦法以某種方式配置Executor將任務移動到隊列末尾,並在條件有效並且任務能夠執行並完成時稍後嘗試執行它們。 所以行爲是這樣的:從隊列 Thread-1取任務,run叫 內run條件尚未生效 任務停止和Thread-1地任務在隊列的末尾和 獲取下一個任務執行 稍後Thread-X(

    0熱度

    1回答

    如果我使用ThreadPoolExecutor我有各種構造函數,我可以傳遞/使用自己的隊列作爲池的工作隊列。 現在我看到一個ScheduledThreadPoolExecutor是ThreadPoolExecutor的子類,但構造函數要少得多。 有沒有辦法使用ScheduledThreadPoolExecutor並仍然使用我自己的工作隊列?

    1熱度

    2回答

    我目前正在編寫多個客戶端將連接到的服務器。通信協議基本上是服務器向客戶端發送任務,客戶端在任務執行時響應。客戶端保持連接到服務器,不應斷開連接。 目前我開始一個新的線程來處理每個客戶端。在精神我目前的解決方案是這樣的:(來源從Java Concurrency in practice) public class ThreadPerTaskWebServer { public static