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 >