Я обрабатываю дерево и хочу ускорить его с помощью GPAR. Я использовал его для простых вещей, но не углублялся в более сложные варианты. Предположим, что я обрабатываю разные ветви дерева их собственными потоками. Скажем, у узла есть имя....

В случае, когда поток генерирует исключение, как я могу дождаться завершения всех потоков, которые не генерировали исключение (чтобы пользователь не запускался снова, пока все не остановилось)? Я использую GPars несколькими способами, поэтому мне...

Я нашел здесь пример fork / join в GPars: Fork / Присоединиться import static groovyx.gpars.GParsPool.runForkJoin import static groovyx.gpars.GParsPool.withPool withPool() { println """Number of files: ${ runForkJoin(new...

Я разрабатываю приложение Grails. Я хочу заблокировать запрос / ответ, создать обещание и позволить кому-то другому разрешить его, то есть где-то еще в коде, и затем сбросить ответ . Что я нахожу действительно странным, так это то, что в...

Я использую gpars для параллельной обработки 250-мегапиксельной таблицы базы данных MySQL. Я создаю 8 потоков gpars, 8 независимых подключений к базе данных и разделяю данные таким образом, чтобы каждый поток работал независимо с разными диапазонами...

Хорошо, новичок в gpars, поэтому, пожалуйста, простите меня, если у этого есть очевидный ответ. Вот мой сценарий. В настоящее время у нас есть часть нашего кода, заключенная в блок Thread.start {}. Это делается для того, чтобы отправлять...

Я изо всех сил пытаюсь достичь цели иметь несколько асинхронных задач с общим тайм-аутом. Хитрость в том, что мне нужно обработать все, что было получено в течение тайм-аута. Например, приведенный ниже код получает значение обеих задач, когда...

У нас есть код на Java с использованием ThreadPoolExecutor и CompletionService. Задачи отправляются в пул большими партиями; результаты отправляются в службу завершения, где мы собираем завершенные задачи, когда они доступны, не дожидаясь завершения...

Я использую fork/join GPars. Когда я выбрасываю исключение после вызова forkOffChild, оно скрывается. Например: def myRecursiveClosure = { boolean top -> try { if (!top) { throw new RuntimeException('child had a...

Я использую Grails 1.4.0.M1 и пытаюсь обновить версию gpars для использования с моим приложением. Поэтому я добавил в BuildConfig.groovy: dependencies{ build 'org.codehaus.gpars:gpars:0.11' } Однако это приводит к следующему...

Когда я запускаю следующий код в консоли (groovy 2.1.3): strings = [ "butter", "bread", "dragon", "table" ] strings.eachParallel{println "$it0"} Я получил: groovy.lang.MissingMethodException: No signature of method:...

У меня есть несколько задач, которые следует выполнять с разными приоритетами. Например, задача A нужна как можно раньше, а задачи B и C могут быть рассчитаны чуть позже, но обязательно после задачи A. При этом приоритет задач B или C в дальнейшем...

Я хочу запускать одни и те же тесты Cucumber в нескольких потоках. В частности, у меня есть набор функций, и запуск этих функций в одном потоке работает нормально. Я использую средство форматирования JSON для записи времени выполнения каждого шага....

Я бы хотел, чтобы мой главный актер завершал работу всех подчиненных актеров, как только первый закончит свою работу. Однако я понятия не имею, как я могу послать широковещательную рассылку от моего хозяина всем подчиненным. Есть ли для этого...