问题标签 [gpars]

当我在控制台（groovy 2.1.3）中运行以下代码时：

我得到：

谁能告诉我我做错了什么？

我有一个循环，如下面的示例所示，它有效。我试图让它平行，但它给出了错误。如何使其并行（或问题出在哪里）？

我已从“org.codehaus.gpars:gpars:1.0.0”更新为“org.codehaus.gpars:gpars:1.1.0”。我的代码在 1.0.0 中运行良好，但在 1.1.0 版中我再也找不到 jsr166y.ForkJoinPool 了。

如何获得正确的 ForkJoinPool？

我正在使用的代码是：

我必须导入 java.util.concurrent.ForkJoinPool 才能获得 ForkJoinPool 类。但在运行时我收到以下错误：

我将GPars用于执行后台任务的并行进程。我使用以下服务来启动一个新的后台线程。

1. 节省堆内存如何限制后台线程的数量？

2. 如何定义处理我的后台任务的 n 个线程的线程池？

   /li>

我有一些任务应该以不同的优先级执行。例如，任务 A 需要尽快，但任务 B 和 C 可能会晚一点计算，但肯定在任务 A 之后。而且，将来任务 B 或 C 的优先级可能会发生变化。

如何使用 GPars 来实现？

真正的商业案例是我需要预先计算一些数据。例如，我有 3 个选项卡，每个选项卡的数据计算需要 30 秒。所以，我想在开始计算第一个选项卡的数据，然后开始计算第二个和第三个选项卡的数据。无法预测接下来会选择哪个选项卡，因此我必须能够更改第二个和第三个任务的优先级。

我正在尝试清除一个集合并同时更新它。它有孩子，在集合中查找当前项目并异步删除它们将为我节省大量时间。

步骤 1. 找到集合中的所有项目。第 2 步。一旦我知道这些项目是什么，就创建一个流程来删除它们。

错误消息是：非法尝试将集合与两个打开的会话相关联

我猜是因为我找到了项目，然后分叉，这会创建一个新会话，以便在分叉之前构建集合，并使用新会话来删除项目。

我需要收集当前线程中的项目，否则我不确定状态会是什么。

我有这个 fork/join 计算的例子。有人可以简短地描述一下它是如何在这里工作的吗？

发送给 gpars actor 的消息是否被复制或引用？如果我发送一个包含二进制数据的缓冲输出流，它是正确引用的，还是被复制的？字符串或其他类型的数据如何工作？演员是否有某种消息队列？
谢谢。

我在使用 grails 2.3.x 和 async 时遇到了一些奇怪的行为。我正在用这段代码做一些测试：

但在我的日志中我得到：

实际上任务（和 onError 闭包）已执行，但 onComplete 不是（当然）！

我究竟做错了什么？

除了 Thread.sleep() 实际代码取自文档： http: //grails.org/doc/latest/guide/async.html

Thread.sleep() 由于某种原因与 GPars 不兼容吗？

我们有一些使用 ThreadPoolExecutor 和 CompletionService 的 Java 代码。任务大批量提交到池中；结果转到完成服务，我们在可用时收集已完成的任务，而无需等待整个批次完成：

池中的工人总数为 MAX_NUMBER_OF_WORKERS；在没有可用工作人员的情况下提交的任务排队；最多可以排队 20 个任务，之后，任务被拒绝。

这种方法的Gpars对应物是什么？

阅读有关 gpars 并行性的文档collectManyParallel()，我发现了许多潜在的选项： 、anyParallel()、fork/join等，我什至不确定要测试哪些选项。我希望在文档中找到一些提及“完成”或“完成服务”的内容作为比较，但一无所获。我正在寻找一些关于从那些有 gpars 经验的人那里开始的方向/指针。