fork-join

    -2熱度

    1回答

    我想檢查下面的代碼的性能,但每次我順序操作相比,叉連接提供更好的性能。 問題,我想找到最大的整數: public class GetMaxIntegerProblem { private final int[] intArray; private int start; private int end; private int size; pub

    0熱度

    2回答

    我有一個練習的問題。我需要使用fork/join並行機制來找到給定數獨的所有解決方案。我做了一個算法,但它似乎不起作用。它在某個時候停下來,我無法弄清楚爲什麼。 下面的代碼: private static int counter; private Cella[][] sudoku; private int i; private int j; private int theCounter =

    0熱度

    2回答

    如何使用Java 8的Fork/Join框架並行化循環。隨便我沒有使用多線程。我在SO中讀了很多問題。現在我無法在Java 8中實現並行處理列表。任何人都可以幫助我? 我曾嘗試過類似於this link的東西。 routes.stream().parallel().forEach(this::doSomething); 情景就像基於路由列表名單,我需要devide任務並執行我需要一個像fore

    1熱度

    2回答

    我想用叉子來實現雙調排序連接java.So的模型繼承人分揀機 import java.util.concurrent.RecursiveAction; public class BitonicSortTask extends RecursiveAction { private final int array[]; private final int low; p

    2熱度

    2回答

    我似乎無法找到一種方法來在嘗試執行路由解析時捕獲/處理forkJoin中的錯誤。 我爲Account頁面創建了一個路由解析器,它在路由之前應該返回2個請求。現在這裏是我無法解決的部分:如果用戶沒有訂閱,則從服務器返回404。我想處理這個問題,如果發生這種情況,用戶應該被路由到不同的頁面,從他可以訂閱的地方。 import { Injectable } from '@angular/core';

    4熱度

    2回答

    假設我有一個像下面的代碼: Future<Object> executeBy(ExecutorService executor) { return executor.submit(() -> { throw new IllegalStateException(); }); } 有使用ForkJoinPool#commonPool時是沒有問題的,但是當我使用的平

    0熱度

    1回答

    我已經明白,分叉和連接用於多線程,但我不明白什麼,當一個任務分叉時發生。分叉任務是否會導致任務返回計算方法的開始?還是這個任務做了別的事情?如果我想要一個任務跳轉到除計算以外的其他方法,並在分叉時運行,我該如何告訴它這樣做?有什麼可以擴展到(instance).fork();,我可以包含這些擴展來指定它?

    3熱度

    1回答

    工作,我有服務: export class ConfigService { private _config: BehaviorSubject<object> = new BehaviorSubject(null); public config: Observable<object> = this._config.asObservable(); constructor

    0熱度

    1回答

    下面的代碼旨在展示一個簡單的遞歸叉連接的使用(find max),我知道Java JIT可以在一個簡單的單線程循環中更快地實現這一點,但它僅僅用於演示。 我最初使用ForkJoin框架實現了find max,該框架適用於大型雙打數組(1024 * 1024)。 我覺得我應該可以使用ForkJoin框架,只使用Executor.workStealingPool()和Callables/Futures

    1熱度

    1回答

    對於我的工作,我必須開發一個解析非常大的文本文件(〜6800 kb)的小型Java應用程序,所以我正在嘗試優化它以創建更進一步的流程。用equalto(=)分割線作爲第一個分叉任務,並用逗號分割並使用第二個分叉任務進行一些計算。這將導致對單個應用程序執行多個分叉任務的良好性能。 1)首先fork和join過程: @Override protected Map < String, String >