pool

3熱度

2回答

我使用python 2.7使用多::游泳池並行運行我已經簡化下面的例子中工作，但這裏是它的主要依據。它將使用apply_async()函數爲我的字典中的每個人創建一個文件。但是，當我檢查文件是否正確創建時，我注意到有時文件沒有創建。現在，我想我已經做錯了我如何用多::游泳池有什麼建議？ import os from multiprocessing import Pool def ou

-2熱度

1回答

java中的連接池

我需要在Java中創建一個自定義連接池，以便如果用戶請求連接並在使用後返回到池但他可以通過將連接分配給某個變量來維護對連接的引用。既然他已經返回連接池，我可以給任何其他用戶。現在兩個用戶將擁有相同的連接對象，這是錯誤的。如何通過避免這種情況創建連接池？這個問題在面試中被問到。我知道有很多庫可以提供這些功能，但是他們的內部工作是如何實現的。

1熱度

1回答

管理客戶端套接字池

我需要管理從我的Java應用程序到外部服務器的長時間運行的TCP套接字連接。我正在尋找一個好的套接字池，所以我將能夠重新使用套接字。還有另一種解決方案，比org.apache.commons.pool2？

3熱度

2回答

多線程在WebSphere

我有一個多線程的應用程序，所以我實現ExecutorService 5線程池大小 public class SimpleThreadPool { public static void main(String[] args) { ExecutorService executor = Executors.newFixedThreadPool(5); for (int

2熱度

1回答

由Apache Common Pool實現的TCP連接輪詢中沒有持續連接

如何使用Apache公共池來池化TCP連接並重新使用連接？爲了實現一個TCP連接池，我試圖使用Apache公共池（1.6），我使用了張貼在https://javaarchitectforum.com/tag/apache-common-object-pool-example/中的對象池來實現它。我確實希望在啓動與另一臺服務器的連接時看到持久的TCP連接，並將其用於其他後續連接請求。問題是，我

-1熱度

1回答

Pythons多處理池不做任何事

我寫了下面的幫助函數來並行運行任意函數。 import multiprocessing def runParallel(fns=[], args=[]): print('Starting multiprocessing with %i cores' % (multiprocessing.cpu_count() - 1)) pool = multiprocessing.Po

11熱度

1回答

在GenericObjectPool中創建對象

我正在做GenericObjectPool的研究，將Cipher放在池中，以便可以重複使用。 GenericObjectPool<Cipher> pool; CipherFactory factory = new CipherFactory(); this.pool = new GenericObjectPool<Cipher>(factory); pool.setMaxTotal(10)

-1熱度

1回答

使用python multiprocessing.Pool而不返回結果對象

我有大量的CPU綁定任務，我想並行運行。大多數這些任務將返回類似的結果，我只需要存儲唯一的結果並計算非唯一的結果。下面是它是如何設計的：我使用兩個託管字典 - 一個用於結果，另一個用於結果計數器。我的任務是使用唯一結果鍵檢查這些字典是否找到了結果，並寫入這兩個字典或只增加非唯一結果的計數器（如果必須寫入，則獲取鎖並再次檢查以避免不一致）。我擔心的是：因爲Pool.map實際上應該返回結果對象，

0熱度

1回答

使用multiprocessing.Pool與異常處理

from multiprocessing import Pool def f(arg): if arg == 1: raise Exception("exception") return "hello %s" % arg p = Pool(4) res = p.map_async(f,(1,2,3,4)) p.close() p.join() res.

0熱度

1回答

爲什麼pool.map（func，argument）返回ValueError：需要多個值才能解包

我想在CPU上的多個核心上運行一個python函數，但是我一直得到這個錯誤，說'需要多於1價值解開'。我傳遞兩個參數映射函數第一個參數是我的函數，我想在多個核心上運行，第二個參數是我想作爲參數傳遞給我的函數的元組列表。像這樣 def func(list_obj): temp = list_obj[0] img = list_obj[1] arg = list() a