threadpoolexecutor

0熱度

1回答

我有一個應用程序運行通過多個數據庫，併爲每個數據庫運行所有表上的select查詢並將其轉儲到hadoop。我的設計是一次創建一個數據源連接，並使用獲取的連接池在多個線程中運行選擇查詢。完成此數據源後，關閉連接並創建一個新連接。這裏是異步代碼 @Component public class MySampleService { private final static Logger

2熱度

1回答

阿卡均衡池中有可變大小的線程池執行人

這裏是我的使用情況：我想創建一個大小爲x的平衡池路由器（x是實例的數量/該在確定routees運行時），每個路由都有自己的專用線程。每個路線預計將執行阻止操作。 Akka文檔解釋說您不能更改平衡池的調度程序。這就消除了使用固定調度程序的選項（它將完成我所需要的任務，每個routee的大小爲1的線程池）。從Akka documentation：的BalancingPool自動使用其route

2熱度

2回答

同步任務生產者/消費者使用的ThreadPoolExecutor

我試圖找到一種方法在下列情況下使用ThreadPoolExecutor：我有一個單獨的線程生產和線程池提交任務一任務提交是同步的，並且將會阻塞，直到在任何給定時間任務可以由任務啓動，只有固定數量的任務可以並行執行。無限數量的同時運行的任務可能會導致內存耗盡。在提交任務之前，生產者線程始終檢查自第一個提交的任務以來還沒有超過一些最大構建時間。如果超過，則線程關閉，但當前在線程池上運行的任何任務

4熱度

3回答

的ThreadPoolExecutor：獲取正在執行

我使用ThreadPoolExecutor執行在後臺多長時間運行的任務的具體Runnable接口的ThreadPoolExecutor池大小是4所以正在增加超過4任務時，他們都推到隊列中，並且當一個4個任務完成後，一個任務從隊列中移出執行。我想知道有什麼方法可以訪問Runnable當前正在執行的對象，而不是隊列，即前4個任務。目標：我想要在任何給定點上獲得當前任務的狀態，在mThreadPoo

0熱度

1回答

蟒蛇多線程，我怎麼能在一次

運行多個操作我試圖SFTP發佈到遠程機器與我的功能 def copyToServer(hostname, username, password, destPath, localPath): transport = paramiko.Transport((hostname, 22)) transport.connect(username=username, password=p

1熱度

2回答

如何知道哪個特定的runnable在我的threadPoolExecutor中死亡？

我正在使用newFixedThreadPool()線程固定量，需要能夠知道什麼時候可運行的一個已經死了，知道哪些具體運行的是死了一個。對此的一個解決方案是將Runnables作爲Thread對象包裝並調用isAlive()。線程運行，因爲他們應該有，但因爲aThread.start()永遠不會被執行者調用總是返回false這是沒有用的。我認爲在run()函數的開始處使Runnables觸發一

0熱度

1回答

Java - 根據請求關閉併發線程

我試圖構建一個程序，試圖解密使用AES加密爲學校項目加密的文件。我有一個約100,000個英語單詞的列表，並且希望在程序中實現多線程以優化文件中每個單詞嘗試解密所花費的時間。我有試圖阻止字典的休息時被搜查解密成功完成事件的一個問題 - 「試圖關閉」被打印到控制檯，但現在看來，該線程將繼續通過工作執行程序停止分配新線程之前的其餘字典。 private void startThreads(){

1熱度

1回答

爲什麼ThreadPoolExecutor $ Worker擴展AbstractQueuedSynchronizer

我知道一些關於AbstractQueuedSynchronizer的細節。它是用於創建狀態相關類或同步器的框架。但我沒有得到在ThreadPoolExecutor的Worker中擴展這個類的要點。 private final class Worker extends AbstractQueuedSynchronizer implements Runnable 所看到下面的東西Worker類

0熱度

2回答

Executor服務中的依賴線程 - Java

我正在處理程序中的多個線程。有一些獨立的線程，一些線程在開始執行之前依賴於其他線程的完成。目前，如果它所依賴的仍然是運行的線程，然後等待它的完成我在做這個 for (final String inElementId : inElements) { Thread thread = threadsMap.get(inElementId); if ((thread != null

1熱度

3回答

Java - 平衡ThreadPoolExecutor公平地給線程並行請求

我開發了一段多線程的代碼。此代碼在Web應用程序中調用，因此可能由多個線程（請求）並行執行。爲了保持這個代碼將要創建的線程數量（通過被幾個並行請求調用），我使用一個靜態共享的ThreadPoolExecutor（Executors.newFixedThreadPool(nbOfThreads)）。所以我確信這段代碼永遠不會創建超過nbOfThreads的線程。要跟蹤給定請求中涉及的任務並等待它們完