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() {