腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(120)
视频
沙龙
3
回答
不可能向ForkJoinPool提供线程facory或名称模式吗?
java
、
java.util.concurrent
我想为工作窃取池所使用的ForkJoinPool线程设置名称,由或到目前为止,我还没有找到在这个ExecutorService使用的线程上设置自定义名称的方法,有办法吗?
newWorkStealingPool
()基本上提供了一个ForkJoinPool,但是ForkJoinPool也没有一个具有提供名称模式的公共构造函数。
浏览 4
提问于2015-12-16
得票数 16
回答已采纳
2
回答
连续运行ExecutorService任务
java
、
concurrency
、
executorservice
我想使用
newWorkStealingPool
()方法来获取线程,并每隔1个sec连续运行它们。executor.scheduleAtFixedRate(task, initialDelay, period, TimeUnit.SECONDS);ScheduledExecutorService executor = (ScheduledExecutorService)Executors.
newWorkStealingPool
()java.util.conc
浏览 4
提问于2018-03-04
得票数 1
2
回答
在Java8中,Executors.
newWorkStealingPool
()是否也提供了一个任务队列?
java
、
multithreading
、
java-8
、
executorservice
、
work-stealing
是否有与Java 8的Executors.
newWorkStealingPool
()一起使用的挂起的任务队列?例如,假设# available核心为2,而Executors.
newWorkStealingPool
()为空,因为2个任务已经在运行。那么,如果第三个任务提交给窃取工作的执行者会发生什么呢?
浏览 6
提问于2016-02-24
得票数 5
1
回答
要提交多少个与
newWorkStealingPool
一起使用的调用?
java
、
multithreading
我正在读关于Executors.
newWorkStealingPool
的文章,我很想知道如何设置它。e.printStackTrace(); ExecutorService workPool = Executors.
newWorkStealingPool
浏览 0
提问于2019-10-16
得票数 0
回答已采纳
1
回答
结合调度程序和执行器服务的咖啡因
java
、
caching
、
java-8
、
caffeine-cache
我在以下配置中使用咖啡因: .executor(
newWorkStealingPool
return forScheduledExecutorService(newSingleThreadScheduledExecutor());我是否正确地假设onRemoval方法将在
newWorkStealingPool
浏览 2
提问于2021-06-23
得票数 2
回答已采纳
1
回答
将排序与Java期货合并
java
、
mergesort
、
concurrent.futures
我正在尝试编写一个使用java期货的合并排序算法。目前我使用期货的程序比标准的合并排序算法要慢。我更喜欢使用java期货而不是叉连接,因为我目前正在学习java期货。我试图在并行流中工作,并建议今后最好有一半的工作和一半的工作在主线上。import java.util.List;import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors
浏览 5
提问于2022-03-15
得票数 0
回答已采纳
1
回答
如何使用Spring Integration处理大文件
spring-boot
、
spring-integration
、
spring-integration-dsl
) .split(Files.splitter()) .channel(c -> c.executor(Executors.
newWorkStealingPool
浏览 38
提问于2021-06-29
得票数 0
2
回答
Java8 ForkJoinPool和Executors.
newWorkStealingPool
?
multithreading
、
executorservice
、
fork-join
、
executors
、
forkjoinpool
使用之间的低层次差异是什么?和其中,X是所需的并行级别,即运行的线程。如果可能的话,也让我知道要保留多少线程。
浏览 4
提问于2016-12-27
得票数 37
回答已采纳
2
回答
如何为CompletableFuture::supplyAsync选择执行器
java
、
java-8
、
executorservice
、
threadpoolexecutor
、
completable-future
Executors中有许多选项(newCachedThreadPool、
newWorkStealingPool
、newFixedThreadPool等)如何为我的用例选择正确的方法
浏览 0
提问于2015-10-28
得票数 14
1
回答
newWorkStealingPool
max-线程&命名
java
、
multithreading
、
spring-boot
、
rx-java
、
executorservice
我将rxjava调度程序定义为带有
newWorkStealingPool
- 10 parallelism level的java excecutor service。HttpClientScheduler") return Schedulers.from( Executors.
newWorkStealingPool
subscribeOn(httpClientScheduler); // <-- here I subscribe to
浏览 2
提问于2021-11-08
得票数 1
1
回答
使用Stream<Future>时,ExecutorService不能并行执行线程
multithreading
、
java-8
我使用的ExecutionService如下所示: ExecutorService exe = Executors.
newWorkStealingPool
(parts.size());
浏览 0
提问于2018-06-25
得票数 1
2
回答
Java中的递归感知ThreadPool?
java
、
multithreading
、
recursion
、
concurrency
我一直在寻找一个“递归感知”的java线程池。换句话说,如果我创建一个固定大小为N的固定线程池,然后提交N个任务,那么一切都没问题,只要这些任务不依次向线程池提交额外的任务,然后等待结果。一旦出现这种情况,用Executors.newFixedThreadPool(int nThreads)创建的Executors.newFixedThreadPool(Int NThreads)会挂起并永远不会完成,因为我的ThreadPool已经饱和,没有等待任务不能分配给执行,因为池中的所有线程都在忙着等待它们完成。 我意识到这听起来有点偏执,但我有一个计算密集型的应用程序,我有16,000个任务可以天真
浏览 4
提问于2016-01-26
得票数 2
回答已采纳
2
回答
如何在Spring中获取当前用户的Callable
spring
、
spring-boot
、
spring-security
、
callable
boolean run(List<Callable<Integer>> callables) { ExecutorService executor = Executors.
newWorkStealingPool
浏览 50
提问于2018-06-27
得票数 1
5
回答
Java 8流在字段上forEach内部的干扰
java
、
concurrency
、
java-8
、
java-stream
java 8流的愚蠢程序: ExecutorService executor = Executors.
newWorkStealingPool
浏览 2
提问于2017-06-16
得票数 5
回答已采纳
1
回答
ExecutorService和ForkJoinPool
java
、
multithreading
、
deadlock
我有一个ExecutorService,如下所示-我有一个元素列表( list )和一个操作(称为A),我需要在这个列表中的每个元素上应用它们。列表可以包含介于1到1000之间的任意数量的元素。该操作是可调用类型的。在operations内部,它调用另外两个服务B和C。B和C也作为异步操作运行,并提交到同一个线程池。CompletionService<T> completionServ
浏览 7
提问于2016-02-26
得票数 2
回答已采纳
1
回答
这个并行和程序,使用分而治之,不会终止。
scala
、
parallel-processing
{Callable, ExecutorService, Executors, Future} def sumP(ints
浏览 1
提问于2018-03-06
得票数 1
回答已采纳
1
回答
线程安全的ArrayList合并:这会起作用吗?
java
、
multithreading
、
concurrency
、
thread-safety
private static final ExecutorService ES = Executors.
newWorkStealingPool
(); public Future<List<String
浏览 9
提问于2020-06-12
得票数 3
回答已采纳
1
回答
使用CompletableFuture supplyAsync的集合进行并行处理,然后收集结果
java
、
asynchronous
、
java-8
、
completable-future
ExecutorService
newWorkStealingPool
= Executors.
newWorkStealingPool
(); } },
newWorkStealingPool
浏览 0
提问于2017-04-09
得票数 1
回答已采纳
1
回答
如何在星火中并发处理多个DataFrames?
apache-spark
我(非常)对火花很陌生,所以我的术语可能已经过时了,但我想做的是: 我目前的程序大致是: 结果是时间戳=>文件的地图(例如20171027 => "s3://foo/2
浏览 1
提问于2017-10-27
得票数 1
1
回答
仅在ExecutorService中提交任务时设置变量值
java
、
concurrency
、
executorservice
、
java-threads
以下是代码: ArrayList<Callable<Boolean>> callables
浏览 0
提问于2018-03-03
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券