问题标签 [gpars]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
groovy - 调用 eachParallel() 时的 Groovy (GPars) 和 MissingMethodException
当我在控制台(groovy 2.1.3)中运行以下代码时:
我得到:
谁能告诉我我做错了什么?
grails - 尝试使循环与 GPar 并行失败
我有一个循环,如下面的示例所示,它有效。我试图让它平行,但它给出了错误。如何使其并行(或问题出在哪里)?
multithreading - Gpars with ExistingPool Error jsr166y.ForkJoinPool not found
我已从“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 类。但在运行时我收到以下错误:
java - 限制 Gpars 中的线程数?
我将GPars用于执行后台任务的并行进程。我使用以下服务来启动一个新的后台线程。
节省堆内存如何限制后台线程的数量?
如何定义处理我的后台任务的 n 个线程的线程池?
/li>
concurrency - 在 Gpars 中设置任务或池优先级
我有一些任务应该以不同的优先级执行。例如,任务 A 需要尽快,但任务 B 和 C 可能会晚一点计算,但肯定在任务 A 之后。而且,将来任务 B 或 C 的优先级可能会发生变化。
如何使用 GPars 来实现?
真正的商业案例是我需要预先计算一些数据。例如,我有 3 个选项卡,每个选项卡的数据计算需要 30 秒。所以,我想在开始计算第一个选项卡的数据,然后开始计算第二个和第三个选项卡的数据。无法预测接下来会选择哪个选项卡,因此我必须能够更改第二个和第三个任务的优先级。
grails - Grails、Promise API 和两个开放会话
我正在尝试清除一个集合并同时更新它。它有孩子,在集合中查找当前项目并异步删除它们将为我节省大量时间。
步骤 1. 找到集合中的所有项目。第 2 步。一旦我知道这些项目是什么,就创建一个流程来删除它们。
错误消息是:非法尝试将集合与两个打开的会话相关联
我猜是因为我找到了项目,然后分叉,这会创建一个新会话,以便在分叉之前构建集合,并使用新会话来删除项目。
我需要收集当前线程中的项目,否则我不确定状态会是什么。
groovy - 分叉/连接计算
我有这个 fork/join 计算的例子。有人可以简短地描述一下它是如何在这里工作的吗?
groovy - 发送给 gpars actor 的消息是否被复制或引用?
发送给 gpars actor 的消息是否被复制或引用?如果我发送一个包含二进制数据的缓冲输出流,它是正确引用的,还是被复制的?字符串或其他类型的数据如何工作?演员是否有某种消息队列?
谢谢。
grails - grails 2.3.x 异步和睡眠
我在使用 grails 2.3.x 和 async 时遇到了一些奇怪的行为。我正在用这段代码做一些测试:
但在我的日志中我得到:
实际上任务(和 onError 闭包)已执行,但 onComplete 不是(当然)!
我究竟做错了什么?
除了 Thread.sleep() 实际代码取自文档: http: //grails.org/doc/latest/guide/async.html
Thread.sleep() 由于某种原因与 GPars 不兼容吗?
groovy - 从 gpars 并行执行器异步收集结果
我们有一些使用 ThreadPoolExecutor 和 CompletionService 的 Java 代码。任务大批量提交到池中;结果转到完成服务,我们在可用时收集已完成的任务,而无需等待整个批次完成:
池中的工人总数为 MAX_NUMBER_OF_WORKERS;在没有可用工作人员的情况下提交的任务排队;最多可以排队 20 个任务,之后,任务被拒绝。
这种方法的Gpars对应物是什么?
阅读有关 gpars 并行性的文档collectManyParallel()
,我发现了许多潜在的选项: 、anyParallel()
、fork/join
等,我什至不确定要测试哪些选项。我希望在文档中找到一些提及“完成”或“完成服务”的内容作为比较,但一无所获。我正在寻找一些关于从那些有 gpars 经验的人那里开始的方向/指针。