gpars

0热度

1回答

我正在寻找GPars功能，该功能允许分开顺序执行的部分parallized子任务中的大任务。即迭代的ķ数组大小，做各具有THREADCOUNT大小并行任务块的序贯分配。换句话说，不要在第一次迭代数组并且一次提交所有任务，而是在前一个块准备就绪（防止OOM）时按顺序执行分配，即使用分页。类似下面的代码，但不是首先列出页面和提交任务，而是必须按顺序处理页面。 myHugeList.getNext

1热度

1回答

gpars与现有池

我想在gpars中使用gpars GParsPool.withExistingPool 0.12 它预计jsr166y.ForkJoinPool，但看起来像在我有jsr166y jar，没有办法创建该类（？）。我可以创建的唯一的是jsr166y.forkjoin.ForkJoinPool像这样： FJPool fjPool = new FJPool(2); jsr166y.forkjoin.Fo

0热度

1回答

GPars actors模型是否使用用户线程或本地操作系统线程

我知道何时没有消息要处理actor，它不消耗线程，只有在消息到达时才将其附加到线程。然而，我的问题是什么时候一个actor被附加到一个线程它是什么样的线程 - 用户线程或本地操作系统线程？我想基本了解如果在actor中有一些阻塞代码，说一些I/O调用或等待Web服务响应会发生什么？线程是否会被阻塞或线程将被释放并可供其他演员使用？据我所知，如果它是本地线程，那么它将被阻止。但是，如果它是用户线程

4热度

1回答

GPars Actors是否具有容错

GPars中的参与者拥有自己的消息队列（邮箱）。说一个演员有15个待处理的消息，并且系统突然崩溃（比如说由于电源故障）。这15条消息会发生什么。系统启动并再次运行时，消息队列是否会自动恢复？或队列中的消息将丢失？

2热度

2回答

为什么DataFlow变量只能分配一次

我正在探索GPars（Groovy并行系统）库，并且我遇到了DataFlow变量。该文档说数据流变量只能分配一次。但是我找不到这个限制的理由。有人可以告诉我为什么GPars中的数据流变量只能分配一次吗？

0热度

1回答

的Groovy GPars，需要指数推出

使用GPars使用Groovy每个线程，我启动3个线程做并行一些工作...... GParsPool.withPool(3){ result = myList.collectParallel{ processItem(it) } } 这工作得很好，但我需要在封闭的索引代表启动的线程数。不知道如何访问这样的索引，因为没有循环;一切都在并行发生。我尝试使用eac

9热度

2回答

什么是GPars默认池大小？

我以为这会很容易找到，但我失败了。如果我在我的Groovy应用程序中使用GPars并且没有指定池大小将创建多少个线程？有没有设置默认池大小？ // How many threads will be created? What is the default pool size? GParsExecutorsPool.withPool { // do stuff... }

1热度

1回答

GPars与Groovy，当collectParallel（）需要显式同步时？

假设以下并行处理在Groovy/Gpars .... def result GParsPool.withPool(5){ result = idList.collectParallel{processItem(it)} } 如果result仅仅是一个数组列表，并且，假设没有线程访问或操纵processItem()result，并result需要显式同步？我需要知道我应该做这个，而

2热度

1回答

如何获得IntelliJ IDEA识别GPars DSL？

根据GPars User Guide，一旦将GPars jar添加到项目中，IntelliJ IDEA应该能够立即识别GPars DSL。自Groovy 1.8以来，GPars现在已经包含在Groovy发行版中，但是将这一方面添加到IDEA项目似乎没有帮助。有谁知道我如何激活DSL支持？这将是真的很高兴有DSL的关键字被认可，而不是在每个地方都没有强调。注：我使用的IntelliJ IDEA终

2热度

2回答

Actors body中“loop（）”方法的意义是什么？GPars

在Actors体中，我们需要在loop（）方法内写入react（）方法。我想知道这个循环方法与“for”或“while”循环不同吗？ GPars文档说“loop（）与嵌套的react（）块协作，并确保在随后的消息检索中循环。”我不完全明白这一点。根据我的理解，无论我们提供给循环方法的闭包，该方法都会无限次重复执行。那么协调嵌套的react（）块又是什么呢？