futuretask

    0熱度

    1回答

    我已經做了我自己的小併發框架(只是爲了學習目的)由java.util.concurrency包啓發。這是關於Callable/Future機制的。我的下面的代碼是完整的,可編譯並且很容易理解。 我的問題是,有時我碰上了僵局,其中第一線程(main thread)等待從其他線程的信號。但是在主線程進入等待狀態之前,另一個線程已經通知主線程,所以主線程不能喚醒。 FutureTask.get()應該總

    0熱度

    1回答

    我有一個創建並在不同的PaaS部署應用以下方法: private void deployModulesInPaaS() { ExecutorService executor = Executors.newFixedThreadPool(listModules .size()); ModuleParsed mod; for (Iterator

    2熱度

    2回答

    我試圖提高索引我的lucene文件的性能。爲此,我創建了一名工作人員「LuceneWorker」來完成這項工作。 鑑於下面的代碼,'併發'執行變得非常慢。我想我知道爲什麼 - 這是因爲期貨增長到極限,幾乎沒有內存可以執行LuceneWorker的另一項任務。 問:有沒有辦法限制進入執行者的「工人」數量?換句話說,如果有'n'期貨 - 不要繼續並且允許文件首先被索引? 我的直觀方法是我應該用Arra

    0熱度

    2回答

    在編寫計算量大的應用程序時,我嘗試使用SwingWorker類將負載分散到多個CPU核心。然而,這個類別的行爲證明有點奇怪:似乎只有一個核心被利用。 當搜索互聯網,我發現了一個很好的回答這個網站上(見Swingworker instances not running concurrently,通過user268396答案),這 - 除了問題的原因 - 也提到了一個可能的解決方案: 你可以做些什麼來

    0熱度

    1回答

    在我的Java Web應用程序中,我有一個結束大約200封電子郵件的方法。由於電子郵件服務器延遲,整個過程大約需要7分鐘。此批量電子郵件發送必須發生在用戶操作的結果中。我當然不希望用戶在轉發到下一個版本之前必須等待很長時間,而不是說Apache無論如何都不會超時,所以我試圖實現FutureTask來讓進程在單獨的線程中運行,同時繼續其餘代碼如下: Some code; Runnable r =

    1熱度

    1回答

    我們正在使用Future以超時完成任務。當時間限制超過時,我們得到一個TimeOutException。根據thread dump的行爲,我意識到底層線程仍在繼續。 是這樣嗎?它如何處理多線程漫遊? 如果沒有爲從池中移除的線程拋出IOException會怎麼樣? 如果這是真的,底層線程kill的方法是什麼。在我的情況下,它一直在等待外部IO。 線程轉儲的一部分: Thread 29587: (st

    -1熱度

    3回答

    我有一個功能來實現我正在考慮使用FutureTask和可調用的calsses.just想驗證我是否可以使用這個,如果在這種情況下使用這些類是正確的。 它是這樣的:我正在用struts spring hibernate開發一個web應用程序。我必須上傳一個類型爲excel/.csv/.txt的文件,其中包含大約40列/字段和大約1000行。我必須處理該行的每一行和每個字段。這將包括以下子任務: 從細

    4熱度

    1回答

    我在ThreadPoolExecutor中運行多個任務。我初始化它如下: private VideoExportExecutor executor; private BlockingQueue<Runnable> jobQueue; public void initialiseVideoProcessor() { jobQueue = new LinkedBlockingQueu

    1熱度

    1回答

    而compling我的代碼(用-Xlint選項)我得到這樣的警告: receptor.java:286: warning: [unchecked] unchecked call to FutureTask(java.util.concurrent.Callable<V>) as a member of the raw type java.util.concurrent.FutureTask

    1熱度

    1回答

    我試圖找出執行任務的最佳方式,例如,將來發送電子郵件給用戶。 我的想法是在需要發送電子郵件時(在用戶數據庫中存儲數據)以及每天檢查用戶需要發送電子郵件的內容以及使用流星計時器功能。 // 7 hours in millisec. Meteor.setTimeout(function() { Meteor.call("sendReminderEmail", ...); }, 2.52e