gpars

1熱度

1回答

如何使用Groovy實現並行/並行數據庫查詢？我想從數據庫中統計所有表中的行數（select count(*) from $TABLE），並將計數寫入單獨的文件。一些表格有數百萬行，需要幾分鐘才能計數，許多表沒有行。我希望教Groovy分離每個計數請求，等待結果，抓取列表中的下一個表格，等等。我將此功能添加到現有的Groovy腳本中，該腳本很實用並且可行。這是我到目前爲止有： retriev

2熱度

1回答

GPars語法不熟悉

我來自Java背景，並且我在同一時間學習Groovy和Gradle，因爲我的目標是另一個。： - /我也需要GPars的東西，因爲速度和並行性是一個問題。無論如何，我看到這個GPars的例子，我有一些問題，我認爲它們是語言上的細微差別，而不是圖書館問題，我還不明白。 //check whether all elements within a collection meet certain cri

-3熱度

1回答

2015年8月24日開放海豚狀態

此庫在2015年8月24日的狀態如何？ web page有幾個月沒有動作。

2熱度

1回答

叉/聯接計算

我有叉/聯接計算的示例。有人能否簡要介紹一下它在這裏的工作原理？ def quicksortForkJoin(numbers) { withPool { runForkJoin(0, numbers) {index, list -> def groups = list.groupBy {it <=> list[list.size().intdiv(2)]}

2熱度

1回答

消息是否發送給gpars參與者複製或引用？

消息是否發送給gpars參與者複製或引用？如果我發送包含二進制數據的緩衝輸出流，它是正確引用的，還是被複制？字符串或其他類型的數據如何工作？是否有演員的消息隊列？謝謝。

0熱度

2回答

使用grails和gpars處理大量數據

我有一個Grails應用程序，每天在午夜運行一項作業。在我的示例應用程序我有10000條Person記錄，並做石英工作如下： package threading import static grails.async.Promises.task import static groovyx.gpars.GParsExecutorsPool.withPool class ComplexJob

1熱度

1回答

限制Gpars中的線程數量？

我使用GPars來執行後臺任務的並行進程。我使用以下服務來啓動一個新的後臺線程。保存堆內存如何限制後臺線程的數量？如何定義處理我的後臺任務的n個線程的線程池？ import jsr166y.ForkJoinPool class TaskService { private pool = new ForkJoinPool() def executeAsync(args, closur

1熱度

2回答

Grails，Promise API和兩個打開的會話

我想清除一個集合並同時更新它。它有孩子，找到收藏中的當前項目並異步刪除它們會爲我節省很多時間。第1步。找到集合中的所有項目。第2步。一旦我知道這些項目是什麼，分叉進程刪除它們。 def memberRedbackCriteria = MemberRedback.createCriteria() // #1 Find all the items in the collection.

3熱度

1回答

我該如何平行GPars Actors？

我對GPars演員的理解可能會關閉，所以如果我錯了，請糾正我。我有一個Groovy應用程序來輪詢Web服務的工作。當找到一個或多個作業時，它會將每個作業發送到我創建的DynamicDispatchActor，並處理作業。作業是完全獨立的，不需要將任何東西返回到主線程。當一次有多個工作進來時，我希望他們能夠並行處理，但無論我嘗試什麼配置，都需要首先進行處理。爲了給出一個代碼示例： def pool

1熱度

2回答

完成所有工作後終止現有游泳池

好吧，全新的gpars，請原諒我，如果這有一個明顯的答案。這是我的場景。我們目前有一段代碼被包裝在一個Thread.start {}塊中。它這樣做可以將消息發送到後臺的消息隊列，而不會阻止用戶請求。我們最近碰到的一個問題是大量的工作，用戶可能會執行另一個操作，導致這個塊再次執行。由於它是線程化的，第二批消息可能在第一批導致損壞的數據之前發送。我想改變這個過程作爲一個隊列流與gpars一起工作。