fork-join

    3热度

    2回答

    我在java中使用叉式连接池进行多任务处理。现在我遇到了一种情况:对于每一项任务,我需要点击一个url然后等待10分钟,然后再次点击另一个url来读取数据。现在的问题是,对于那些10分钟我的CPU空闲,并没有开始另一项任务(超过分叉连接池中定义的那些)。 static ForkJoinPool pool = new ForkJoinPool(10); public static void mai

    0热度

    1回答

    该作业是转换src数组中的值并将新值写入dst数组。 当我在while循环 val height: Int = 4; val numTasks: Int = 2; var tasks = scala.collection.mutable.ListBuffer.empty[ForkJoinTask[Unit]] val jump: Int = src.height/numTasks va

    0热度

    1回答

    我想在fpga中传输fork-join问题。 分叉连接的意义在于,将有许多小组件(> 100)访问内存组件,处理少量循环(〜50)的输入数据(几个32位向量),而不需要它们之间的交互,然后返回用于访问另一个内存的数据。 这听起来是一种情况,在互连方面,我应该使用传统的总线解决方案,或者我应该转向那些在系统级工具(Qsys altera)中提供的基于NoC的结构?

    0热度

    2回答

    由于每SV LRM section 9.3.2 for(int j=1; j <=3; ++j) fork automatic int k = j; begin .... # use k here end join_none 这是如何在一个循环中创建一个fork工作。我已经尝试过,它的工作原理。但是,如果我想在循环中创建join而不是join_no

    2热度

    1回答

    我有一个错误,在生产中出现了两次,其中一个fork/join池停止工作,即使它有工作要做,并且正在添加更多工作。 这是我到目前为止解释为什么要完成的任务队列已满并且任务结果流停止的结论。我有线程转储,其中我的任务生产者线程正在等待fork/join提交完成,但没有任何ForkJoinPool工作线程正在执行任何操作。 "calc-scheduling-pool-4-thread-2" #65 pr

    2热度

    2回答

    我有一个家庭作业,需要在Java中使用数独求解器的顺序和并行版本(使用ForkJoin框架,并行版本为)。 我写了顺序的一个,它工作正常。算法的思想是一个简单的回溯练习:对于每个单元格(从表格的左上角开始)尚未填充,填充它(依次,并一次一个)与所有合法候选人(从1到9)直到你到达矩阵的最后(第9列第9列)。如果您已达到最终结果,则增加解决方案编号。 我认为实施并行版本只是为每个有效的候选人找到一个

    3热度

    1回答

    我是hadoop生态系统的初学者。我正在尝试分派三个不同的作业,我想从同一个通用workflow.xml文件中调用,但将不同的参数传递给每个子工作流程。 子工作流程: <?xml version="1.0" encoding="UTF-8"?> <workflow-app xmlns="uri:oozie:workflow:0.4" name="special-fork"> <glo

    1热度

    1回答

    如何创建非守护进程fork /连接池? 如果我创造这样的方式池: ForkJoinPool pool = ForkJoinPool.commonPool() 它会停止所有任务时,我的程序退出,是什么阻止它正确的方法?

    5热度

    1回答

    在我的Angular2-typescript应用程序中,我使用forkJoin仅在所有并行HTTP调用完成后才返回Observable。 问题:认购回调一直被无限期执行 这里是我的代码: http.service import {Http} from "@angular/http"; constructor (private _http: HTTP) {} makeGetRequest(.

    1热度

    1回答

    考虑50,000个对象的集合。 每个对象通过其doWork()方法每次迭代产生10次双打。 有一个连续的while循环遍历50,000个对象中的每一个,并调用doWork()。 之后,创建的10个双打中的每一个都必须通过调用每个对象的process()来处理。 while循环内的最后一步必须对每次迭代中产生的双精度进行求和,然后记录输出。 设计是否取决于完成doWork()和process()所花