腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(5222)
视频
沙龙
8
回答
Java
:
在
一定
队列
大小
后
阻塞
提交
的
ExecutorService
、
、
、
我正在尝试编写一个解决方案,其中单个线程产生可以并行执行
的
I/O密集型任务。每个任务都有大量
的
内存数据。因此,我希望能够限制当前挂起
的
任务
的
数量。new LinkedBlockingQueue(maxQueue)); 然后executor.submit(callable)抛出RejectedExecutionException 当
队列
填满并且所有线程都已经很忙时我能做些什么executor.submit(callable)是否
在
队列
已满且所有线程都繁忙时<em
浏览 145
提问于2010-12-24
得票数 91
回答已采纳
1
回答
背压
ExecutorService
、
、
、
、
我对
ExecutorService
有以下要求 limited并发处理任务
的
数量(线程),最好是configurablewhen所有线程,随后
提交
的
任务获取queued.the
队列
应该应用backpressure:,如果
提交
的
任务太多且
队列
已满,则
提交
block.the
阻塞
提交
时可以有超时:如果任务在给定时间内未
提交
,则应抛出异常。生产者(一些是从Kafka读取
的
,
浏览 12
提问于2022-06-07
得票数 1
2
回答
如何等待
ExecutorService
中
的
一个正在运行
的
线程完成分配另一个任务
、
、
、
、
我有一个循环,用固定
大小
的
线程将任务分配给
ExecutorService
,我希望主程序等待threadPool释放它
的
一个线程,以便将另一个任务分配给它。下面是我
的
示例代码:在这个示例代码中,我希望
在
结束时打印finished!,并希望使用
ExecutorService
。public static void main(String[] args) {
ExecutorService
ex = Executors.newFixedThreadPo
浏览 2
提问于2018-06-07
得票数 1
回答已采纳
3
回答
队列
ThreadPool
可能重复: 如果可能的话,我可以如何实现这些代码。
浏览 2
提问于2012-11-02
得票数 3
1
回答
ThreadPool不运行
提交
的
任务
、
、
我对
java
ThreadPool有一个奇怪
的
问题。我对
executorService
的
定义如下:以及稍后
提交
任务:运行一段时间(根据线程池completedTask计数器执行50-100个任务
后<
浏览 1
提问于2011-01-25
得票数 4
回答已采纳
2
回答
以原子方式将第一个元素添加到ConcurrentLinkedQueue
、
、
、
我想以原子
的
方式使用: 几个并发线程将事件推送到
队列
中,其他线程将处理这些事件。
队列
没有绑定,我不想让任何线程等待或被锁定。然而,读取部分可能会注意到
队列
变空了。
在
无锁
的
实现中,读线程不能
阻塞
,而只是结束它
的
任务并继续执行其他任务(即作为
ExecutorService
)。因此,将第一个新事件推入空
队列
的
写入器必须意识到这一点,并且应该重启读取器(即,通过向
ExecutorService</e
浏览 3
提问于2012-07-26
得票数 3
回答已采纳
1
回答
如何在Executor
队列
已满时暂停调用任务
、
、
我有一系列接受数据
的
任务,然后
在
完成处理
后
将其移动到不同
的
任务。这种管道方法
的
一个目标是,无论您有多少文件,应用程序都不会使用太多内存,因为在任何时候都只有一些文件
在
处理,但是每个任务都有不同
的
吞吐量级别,因此我发现任务B
队列
正在建立,因为任务A比任务B处理文件
的
速度更快这些
队列
正在使用内存 因此,我更改了executor servide defn以指定
队列
的
amx
大小</
浏览 1
提问于2014-02-23
得票数 0
6
回答
ExecutorService
,避免任务
队列
过满
的
标准方法
、
我使用
ExecutorService
来简化并发多线程程序。Future<..> ... = exService.submit(..);}
在
我
的
例子中,问题是如果所有的NUMBER_THREADS都被占用了,submit()就不会
阻塞
。其结果是任务
队列
被许多任务淹没。这样做
的
结果是,使用
ExecutorService
.shutdown()关闭执行服务需要很长时间(
ExecutorService
.isTerminated()
浏览 0
提问于2010-02-12
得票数 35
2
回答
有没有办法判断一个程序是否仍在运行某个方法?
我从main中运行了一个生成数据
的
方法,我还派生了一个线程,该线程监视该方法正在写入
的
队列
,如果有数据,它会将其保存到磁盘。我
的
问题是,在过去,我会多线程它,并能够监控其他线程
的
生命周期,但我不确定如何做到这一点,如果它只是主要
的
方法?该方法
的
问题是生成数据很慢,并且一旦清空
队列
,派生
的
文件编写器进程就会停止,并且使用睡眠或!queue.empty()不起作用。我知道
在
最坏
的
情况下,我可以在生成数据
浏览 0
提问于2012-05-30
得票数 0
回答已采纳
2
回答
Java
线程等待和通知
、
、
、
线程A正在从
队列
中提取一些元素,而线程B正在向
队列
中添加一些元素。当线程B向
队列
中添加一些元素时,它应该确保线程A正在工作。
在
Java
中如何做到这一点呢?
浏览 1
提问于2009-05-05
得票数 10
回答已采纳
2
回答
用
java
处理大量数据
的
有效方法
、
我有10亿条未排序
的
记录,它们彼此无关,我必须使用
Java
在
每条记录上调用一个函数processRecord。是否有一种有效
的
方法来处理这个大型数据集?
浏览 0
提问于2018-04-08
得票数 1
回答已采纳
2
回答
如何处理doGet或doPost中潜在
的
长操作?
、
、
、
、
在
HTTP (由应用程序生成,而不是由用户生成)之后,我想发送一封电子邮件。我
的
电子邮件发送过程是正确
的
,但我不确定
Java
服务器是如何工作
的
。我特别关心超时,我想知道我是否以某种方式
阻塞
了一个重要
的
线程。times out sendEmail(...);如果电子邮件服务器关闭,线程将
阻塞
直到我
的
浏览 0
提问于2010-12-21
得票数 2
回答已采纳
1
回答
延迟
队列
与执行器服务相结合
的
问题
、
、
、
我试图用
Java
8为
阻塞
队列
创建一个执行器服务( DelayQueue )。我创建了一个实现可运行和延迟
的
类,并实现了所需
的
方法:BlockingQueue<CurlEvent> queue = new DelayQueue<>(); ThreadPoolExecutor exe
浏览 9
提问于2022-08-08
得票数 0
2
回答
Java
应用程序中
的
任务执行
、
、
、
它
的
功能之一是文件转换(上传文件->转换->存储
在
服务器上)。有些文件可能太大,无法实时转换,所以我决定上传
后
将它们放在共享
队列
中。文件将按上传时间优先转换,即FIFO。我
的
想法是在上传
后
在
控制器中添加任务
队列
。还会有服务执行
队列
中
的
所有任务,如果为空,则等待添加新任务。我不需要调度-任务应该总是
在
队列
不为空时执行。我读过关于
ExecutorService</e
浏览 6
提问于2016-02-03
得票数 0
回答已采纳
1
回答
Executor线程池
的
使用
、
我正在处理executor线程池,以检查是否有对象被插入到
阻塞
队列
中。如果任何对象已经
在
队列
中,一个线程从池中唤醒,并从
队列
中获取对象,将其发送到某个类进行处理。当我
在
for循环中使用它们时,进程
的
运行速度和我预期
的
一样快,但看起来好像出了什么问题。这个逻辑正确吗?core.addMesageToQueue(rbtran, type); 消息添加到
队列
public static void addMessageToQueue(T
浏览 0
提问于2018-11-09
得票数 2
2
回答
使用可调用
的
主线程发生了什么?
、
在
Java
中使用可调用和未来时,当另一个线程执行可调用时,主线程会发生什么情况。它是否处于休眠状态,而另一个线程
在
计算完值
后
唤醒它?import
java
.util.concurrent.*; public static void main(String[] args) throwsInterruptedException, ExecutionException {
浏览 2
提问于2021-01-02
得票数 1
回答已采纳
4
回答
多线程是
队列
契约
的
一部分吗?
、
、
目前,我有一个算法,看起来有点像网页蜘蛛或文件搜索系统,它有一个元素集合来处理,处理元素可以导致排队更多
的
元素。 但是,这个算法是单线程
的
--这是因为我从db中获取数据,并且希望一次只有一个db连接。
在
我目前
的
情况下,性能并不重要--我这样做只是为了可视化,以简化调试。对我来说,使用
队列
抽象似乎很自然,但是使用
队列
似乎意味着多线程--据我所知,大多数标准
的
java
队列
实现驻留在
java
.util.concurrent
浏览 10
提问于2012-06-26
得票数 0
回答已采纳
3
回答
ExecutorService
有一个最大
的
大小
、
有没有办法通过一个庞大
的
数据库,并并行地应用一些作业作为条目的工作台?我试过使用
ExecutorService
,但是我们必须关闭()才能知道池
的
大小
.所以我最好
的
解决办法是:import
java
.util.concurrent.Executors; System.out.println("Thread
浏览 5
提问于2017-06-29
得票数 3
回答已采纳
2
回答
Java
工作线程,终止条件
、
我有三个主线程
的
工作线程。主线程将对象放入BlockingQueue.中如果
队列
没有足够
的
数据,让我们只说一个对象。另外两个线程保持等待状态。一种方法是
在
队列
中传递最后一个脏对象,以便读取和终止其他陈旧
的
线程。还有其他优雅
的
解决方案可用吗?
浏览 6
提问于2012-12-07
得票数 1
回答已采纳
1
回答
在
Java
中关闭
ExecutorService
的
最佳方法
、
我正在尝试用
Java
语言编写异步编程,并且我正在使用
ExecutorService
创建一个由多个线程支持
的
池,以
提交
多个可调用
的
任务,但是我对如何关闭
ExecutorService
几乎没有什么疑问。以下是我
的
原始代码: Future<String> f =
executorSer
浏览 72
提问于2018-08-13
得票数 5
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
干货,一篇文章搞懂Java线程池所有问题
并发编程之Executor,Executors,ExecutorService和ThreadPoolExecutor
深入理解Java线程池:线程池参数调优与技巧
一文总结线程池框架结构体系
java并发编程实战——线程池的使用
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券