3回答
根据这些请求的结果，可能会启动更多请求。 });
在本例中，startRequest将网络请求(Retrofit)添加到requestSubject，这是一个PublishSubject<Observable<SomeResponse>>。具体
浏览 18提问于2017-02-28得票数 0
2回答
在异步任务期间释放线程
、、、、
我有一个系统，它产生了许多必须并行运行的子进程。
然后，当所有子进程完成(或超时命中)时，主线程继续执行。我们在线程计数方面有问题，因此我们希望在等待远程API时尝试释放线程，从而减少活动线程的</
浏览 1提问于2016-05-13得票数 0
回答已采纳
1回答
如何通过合并任务来减少任务数量？
、、、、
我有一大组任务对象。大多数任务都有父任务--需要在此之前执行。大多数任务都有子任务--只有在之后才能执行。关键是，一旦创建了这样一组任务对象，就会经常执行，并且应该通过并行执行任务来利用所有可用的CPU。我遇到的问题是，与任务对象相关的工作量往往太小--调度代码只处理它自己--真正要完成的工作不会显示在分析结果中(grin)。<
浏览 0提问于2013-05-29得票数 1
不知道“并行编程”是什么意思..。但我有两个想法并行编程的正确思想是哪一种？谢谢你的帮助！
编辑:我
浏览 3提问于2012-05-27得票数 1
回答已采纳
我有一个关于将数据下沉到Kafka主题中的流作业和另一个消耗kafka主题中的数据的流作业。我的Kafka集群的分区号配置为3。当我将作业的并行度设置为4时，只有3个插槽在忙于生成数据，并且只有3个消费者子任务获得了数据。 考虑到任务槽数量的限制，我想将并行性改为1。但是，当我将作业的
浏览 230提问于2021-06-16得票数 0
回答已采纳
1回答
例如，在计算Fibonacci数时，我们在重载execute()方法中创建两个子任务，即:a计算n-2.th数，B计算n-1.th数。在本例中，B被生成，A被设置为spawn_and_wait_for_all (这意味着任务A正在等待任务B)。
但是，例如，如果我们必须确定Tribonacci数，那么我们应该有三个子任务。我的问题是，这三个任务中的哪一个应该是spawn_and_wait_for_all来实现最大的<
浏览 4提问于2018-05-26得票数 0
回答已采纳
4回答
我从java.util.concurrent包中遇到了一个名为ForkJoinPool的新类，据我所知，它使用以下场景工作：
通过将自己划分为子任务，每个
浏览 3提问于2018-01-03得票数 1
回答已采纳
2回答
我目前正在创建一个演示项目，向我的团队其他成员展示如何使用TPL来编写更好的代码。，聚合异常将包含500个内部异常，因为在PLINQ中调用的每个其他线程都会抛出一个异常。我的第一个想法是，当TPL达到可以抛出的异常数量限制时，它可能会终止运行。然而，我似乎找不到任何支持这一说法的在线文章或文档。所以我有点被难住了；什么会导致只包含4个异常？编辑:下面的@Dan Bryant将它钉在头上；当我将代码更
浏览 1提问于2011-08-17得票数 1
回答已采纳
1回答
我有一组任务，其子任务按顺序执行。但是，我希望这些子任务按顺序执行，并且只在清除了一组未知的阻止程序时才开始。另一个任务，LetKidConsumeIcecream有类似的子任务: BuyIcecreamForKid、OpenIcecreamForKid、GiveIcecreamToKid、KidEatsIcecream这两者都可以在方法SpoilYourselfWithKid中启动，并以并
浏览 0提问于2018-04-20得票数 0
回答已采纳
2回答
我的用例如下：我想以以下方式向用户展示这一点：
有一个没有全局进度条的主“用户操作”对话框(因为第一个作业未知，而且执行长度实际上是可变的)，这个对话框中的有3个子部分，每个作业一个进度条，第一个</
浏览 3提问于2011-08-12得票数 5
回答已采纳
1回答
我一直在阅读这个关于并行流的。这是相当长的喘息，我理解一切，直到一个部分，有关平行流如何工作。我将引用我难以理解的部分：
某些任务意味着
浏览 1提问于2017-06-17得票数 2
回答已采纳
2回答
我有一个单线程模型任务，它迭代数据集合并定制数据。我希望将集合划分为较小的子列表，并希望每个单独的子列表都能并行执行。我应该使用线程数组(数组的大小是创建的子列表的数量)，还是线程池？
浏览 0提问于2016-02-03得票数 0
1回答
我已经了解到fork join池可以从阻塞或等待的线程中窃取数据。目前的工人似乎是一个明显的候选人。一旦工作者在另一个任务上调用了.join()，那么该任务基本上就被阻塞了。另一方面，我看到许多文章暗示了不同的结论。例如，普遍的共识是，当前工作线程应该在等待分叉任务之前执行工作。有几篇文章讨论了如何使用ForkJoinTask.getSurplusQueuedTaskCount作为平衡队列中的工作<
浏览 0提问于2015-10-15得票数 6
1回答
我正在使用一个网络应用程序中的芹菜来启动一个任务层次。其中每一个都进行一些处理，然后启动几个task_c实例。
目标
每个子任务取决于父任务。父任务不直接依赖于<
浏览 2提问于2013-05-24得票数 10
回答已采纳
我有一个简单的自我包含的模板应用程序示例，可以使用OpenMP任务和依赖子句。在两个步骤中，一个数组的一个位置被从另一个数组中添加3个值，一个从对应的位置和它的左右邻居添加。为了避免数据竞争，我设置了依赖项，以便对于第二次更新中的每个部分，只有在执行第一个更新步骤中各节的相关任务时，才能调度其任务。我得到了预期
浏览 6提问于2022-02-26得票数 1
回答已采纳
1回答
分布式的、同步的批处理
、、、
在当前的Java项目中，我们需要对大量记录进行批处理。一旦完成了这个处理，就必须重新启动并重新处理所有记录。此处理必须并行化，并在多个节点之间分布。
主任务检查是否有任何子任务仍在运行。如果没有，为每批记录创建一个子任务。我们大量使用MongoDB，并考虑在其中持久化子任务</em
浏览 3提问于2017-04-29得票数 4
我有两个遥远的分支：另一个分支是一个子任务-> subtask/subtask1 of feature/feature1我想把subtask/subtask1的上游设置为feature/feature1
由于有多个开发人员在处理同一特性的不同子任务，所以我们的想
浏览 0提问于2018-06-22得票数 0
1回答
并行/并行处理的标准实践？
、、、、
简单地说，在什么用例中，最好有许多进程从队列中获取消息，然后顺序地完成该作业的多个任务，或者让多个任务/进程从队列中获取1 msg，并对其完成任务。 ------> write a blog about it
任务的顺序是无关的他们都需要完成任
浏览 2提问于2013-12-16得票数 2
回答已采纳
1回答
比如说我有一个线程池。我向它提交了一条线索，它继续着它的快乐之路。我想阻塞主线程，直到池为空/所有线程都完成了，最好不要忙着等待。但是线程可以创建自己的线程并将其添加到池中(预先未知的数量).因此，当主线程阻塞时，池可以继续正常地接受和处理线程，这一点很重要。但是，上下文并不重要:我正在执行一个图搜索。我找到了很多解决方案：
CountDownLatch非常接
浏览 1提问于2013-09-15得票数 0
回答已采纳
我想使用一个名为“链接问题”的标准字段
ID :调出可搜索:真架构：@{type=array；items=issuelinks；system=issuelinks}名称:链接问题自定义:假导航:真可排序:真ClauseNames：ID :子任务可搜索: False架构：@{type=array；items=issuelink
浏览 11提问于2022-05-24得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
