Я новичок в языке c и Linux. У меня проблема, связанная с функциями fork(), getpid() и exec(). Я написал программу c, используя вызов fork(), код моей программы выглядит следующим образом: #include <stdio.h> #include <sys/types.h>...

Я ищу неглобальный экземпляр ForkJoinPool , чтобы получить весь отличный параллелизм по умолчанию и семантику выполнения глобального экземпляра с возможностью управления жизненным циклом пула. Я заглянул в исходный код scala.concurrent и...

У меня есть задача выполнить некоторую логику, связанную с коллекцией, в параллельных потоках и сравнить ее с однопоточным режимом. Из этого вопроса многопоточность для чтения файла в Java я заметил что чтение файлов не является задачей для...

Другой последовательный код, который я написал, работает отлично, но эта параллельная версия не дает никакого вывода, она просто печатает привет, я тестирую ее с помощью «эй», она даже не доходит до этой строки, т.е. она застревает в методе вызова, я...

В Java 8 есть два способа запуска асинхронных вычислений — CompletableFuture и ForkJoinTask . Они оба кажутся довольно похожими — внутренние классы CompletableFuture даже расширяют ForkJoinTask . Есть ли причина использовать один над другим?...

Задача состоит в том, чтобы преобразовать значения из массива src и записать новые значения в массив dst. Когда я создаю ForkJoinTasks в цикле while val height: Int = 4; val numTasks: Int = 2; var tasks =...

У меня есть параллельный поток, как это: mylist.stream().parallel().map(transform::docPDFTypeToItem) .map(fdUtil::createEdiLine).forEach(document::add) это работает на моих двух процессорах теперь я пытаюсь увеличить размер forkjoinpool,...

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

Я пытаюсь присоединиться к пользовательскому Observable (rxjs 5.5.6) import { forkJoin } from 'rxjs/observable/forkJoin'; forkJoin( this.resources.loadRefsCatalog() ).subscribe((res) => { // I'm never executed :( }); и цель public...

@Effect() initDomain$: Observable<Action> = this.actions$.pipe( ofType('INIT_DOMAIN'), mergeMap((action: any) => this.http.get('https://demo.api/url1.php').pipe( switchMap((data) => [ {type: 'INIT_IT',...

Мне нужно вызвать три метода из метода. Эти три метода, в свою очередь, вызывают различные службы REST или SOAP. Я хочу сделать обработку этих трех методов асинхронной, т.е. остальные вызовы и вызовы мыла выполняются параллельно. Кроме того, я...

public class S3ButcketTest { public static void main(String args[]) { System.setSecurityManager(new RMISecurityManager()); ForkJoinPool pool = new ForkJoinPool(1); System.out.println("main: "+Policy.getPolicy()); pool.execute(new...

У меня есть требование обрабатывать список запросов параллельно с помощью forkJoin в Angular 5. Я взял ссылку из этой ссылки Рецепты RxJS: 'forkJoin' с прогрессом выполнения для массовых сетевых запросов в Angular У меня здесь одна проблема. Я...

Краткое объяснение Как обработать массив Observable (например, в forkJoin ) с передачей некоторых данных для каждого Observable, которые мне нужно использовать в _2 _ & _ 3_? const source = {animal: 'cat', fruit: 'apple', color: 'blue'} const...