gpars

-1熱度

1回答

GParsPool.withPool和GParsPool.withExistingPool有什麼區別？

GParsPool.withPool和GParsPool.withExistingPool有什麼區別？我不明白文檔中解釋了什麼。

1熱度

2回答

我想有一個方法調度一個異步任務，並立即返回。我不需要等待結果。我想是這樣工作的： /** * runs a job and return job id for later montoring. */ def int runJob(){ int jobId = createJob() // returns immediately task{ doSomthing

-1熱度

1回答

gpars在詹金斯管道插件中創建並行作業

我的環境是Tibco，我有200到300個服務。我的設計需要並行地觸發所有這些服務的「停止」命令。請提供一些關於我如何處理（編碼）Gpars中的線程機制的信息。例子會有所幫助。

0熱度

2回答

GPars - 我如何知道演員是否忙？

我試圖在Java中使用GPars來處理幾種類型的消息。每個消息類型都有一個actor。但消息處理需要花費大量的時間，而消息不斷傳來。在演員很忙的時候，我需要忽略即將到來的消息（只是扔掉它們）。我怎麼知道，如果一個演員GPars忙？我知道Actor.isActive()方法，但我不太確定它是什麼東西（JavaDoc非常模糊和不清楚），我找不到任何有用的信息。

0熱度

1回答

Groovy XmlSlurper與並行操作

我解析了一些rss的xml飼料，並需要擴大描述字段中的一些網址。現在我的代碼寫成 items.collect { it.description = FullText.expand(it.description) return it } 在這種情況下，裏面的URL請求一個接一個，從而使得其工藝非常緩慢。所以，我要像做 items.collectParallel {

0熱度

1回答

gpars dataflowQueues處理或管道似乎只能在df.val請求上觸發

需要一些幫助。看看Gpars數據流/管道，但我不明白的東西如果你看看下面的例子（我已經完成了這與運營商，piplines，chainWith和同樣的問題）。在這個例子中，我已經使用過任務，但可能很容易就沒有，同樣的問題也體現出來。在這個例子中，我設置了兩個DataflowQueue，一個用於初始條件，另一個用於對謂詞進行評估的結果。然後我佈置一個管道，用於評估反對對謂詞的輸入的輸入（甚至測試）

0熱度

1回答

如何通過GPars中的主演員終止所有從屬角色？

我想讓我的主演演員在第一個演員完成作品後儘快終止所有奴隸演員。但是，我不知道如何從主人發送廣播給所有的奴隸。有沒有一個函數或編程模式呢？解決這個問題的另一種方法可能是給主人一個所有奴隸的列表並通過它們循環，發送每個消息終止，但奴隸也需要主人作爲屬性，我認爲這是一個問題： import groovyx.gpars.actor.Actor import groovyx.gpars.actor.D

2熱度

1回答

GParse call BackendService async

我試圖在後端調用中實現異步，我一直在閱讀，似乎GParse是一個很好的庫來實現這一點，但它並不清楚我如何可以在一個正確的方式。誰能幫我？這是我的例子： def itemsResults def locationResults def itemsNearLocation GParsPool.withPool { itemsResults = {searchM

0熱度

1回答

Gpars withPool方法從管道中調用

我在'PreVerifymanager.groovy'中實現了我的GParsPool.withPool，如下所示。 import groovyx.gpars.GParsPool public class PreVerifyManager { static final THREADS = 3; public void callMe() { PreVerify

0熱度

2回答

groovy應用與gpars在很多迭代後變慢

我使用gpars並行處理250M行的MySQL數據庫表。我創建了8個gpars線程，8個獨立的數據庫連接，並以這樣一種方式劃分數據，即每個線程獨立運行在不同的行數範圍內......這是一種便宜的MapReduce概念。在覈心，邏輯是這樣的： withExistingPool(pool) { connection_array.collectParallel() {