gpars

-1зной

1ответ

В чем разница между GParsPool.withPool и GParsPool.withExistingPool?

В чем разница между GParsPool.withPool и GParsPool.withExistingPool? Я не понял, что было объяснено в документации.

-1зной

1ответ

gpars для создания параллельных заданий в плагине конвейера для jenkins

Моя среда - Tibco, где у меня есть от 200 до 300 сервисов. Мой дизайн должен запускать команду «stop» для всех этих служб параллельно. Просьба дать некоторое представление о том, как я обрабатываю (ко

0зной

1ответ

Groovy XmlSlurper с параллельной операцией

Я разбираю некоторые RSS-ленты rss и вам нужно развернуть некоторые URL-адреса в поле описания. Теперь мой код записывается как items.collect { it.description = FullText.expand(it.description)

0зной

1ответ

Нити Gpars.withPool в конечном итоге прекращают выполнение после многократного повторения

пытался выполнить параллельные операции с Gpars. Gpars.withPool(6) { someList.eachParallel { println "${Thread.currentThread}" } } Первоначально кажется, работает Thread[ForkJoinPool

0зной

1ответ

gpars dataflowQueues обработка или конвейеры только срабатывает по запросу df.val

нужна помощь. Глядя на потоки данных/конвейеры Gpars, но что-то я не понимаю , если вы посмотрите на пример ниже (я сделал это с операторами, трубопроводами, цепью и попал в ту же проблему). В этом пр

0зной

1ответ

Как прекратить действие всех подчиненных актеров через главного актера в GPars?

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

0зной

1ответ

Gpars withPool метод вызван из Pipeline

У меня есть мой GParsPool.withPool, реализованный в 'PreVerifymanager.groovy', как показано ниже. import groovyx.gpars.GParsPool public class PreVerifyManager { static final THREADS = 3;

0зной

1ответ

Как сделать вывод данных из внешнего процесса потоком?

Я написал небольшой метод для выполнения функции git командной строки и захватить его вывод: def git(String command) { command = "git ${command}" def outputStream = new StringBuilder()