pool

11熱度

1回答

我正在做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回答

彙集httpclient的最佳方式是什麼？

我的主要目標是以沉默或某種方式彙集一個httpclient，並且我想調用一個方法給我一個httpclient ...因爲我認爲它對於每個其他的調用都有太多的資源用法添加一個新的httpclient實例並設置事情等...是否有最佳做法呢？

-1熱度

1回答

如何關閉hikariCP池上的當前連接？

我需要你的幫助。我使用hikariCP進行池連接，當我創建一個查詢到數據庫時，我遇到了一些麻煩。建立連接並在數據庫發生進程但響應時間線長達大約兩個小時，並且我想手動關閉連接。我設置了超時時間config.setConnectionTimeout(TimeUnit.MINUTES.toMillis(2L)); 但它沒有幫助。它設置了嘗試連接的時間，但沒有設置查詢時間和獲得響應的時間。我如何手動關閉連

0熱度

1回答

不兼容的類型：com.rh.host.Validator <T>無法轉換爲com.rh.host.Pool.Validator <T>

我使用generic object pooling重用Cipher對象。 Eracom Pool< Cipher> pool = PoolFactory.newBoundedBlockingPool(10, new CipherPicker("DESede/CBC/NoPadding"), new CipherPickerValidator()); PoolFactory public sta

-2熱度

1回答

java中的連接池

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

1熱度

1回答

管理客戶端套接字池

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

2熱度

1回答

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

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

1熱度

2回答

Python的ActionScript等價於apply（）/ call（）方法嗎？

我正在寫一個非常簡單的函數，用於我的Django項目中，只有當應用程序處於調試模式時才顯示多個頁面。在AS3中，您可以使用該方法的調用或應用方法將方法參數應用於其他方法。讓我證明： public function secureCall(...arguments):void { if (SECURE == true) { // reference the 'call' meth

-1熱度

1回答

Pythons多處理池不做任何事

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