腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
BlockingQueue
在
Java
中
的
异步
等效
项
?
、
、
我正在寻找一个与
java
.util.concurrent.
BlockingQueue
异步
(非阻塞)
等效
的
队列。它
的
界面将包括: public interface AsynchronousBlockingQueue<E> { public synchronized void add(E element); } 如果这很重要
浏览 25
提问于2019-10-17
得票数 6
1
回答
C#是否有可能中断ThreadPool
中
的
特定线程?
、
、
、
、
假设我
在
ThreadPool
中
对一个工作
项
进行了排队,但是如果没有数据要处理(从
BlockingQueue
读取),该工作
项
就会阻塞。如果队列是空
的
,并且不再有工作进入队列,那么如果我想中断阻塞任务,我必须调用Thread.Interrupt方法,但是如何使用ThreadPool来做同样
的
事情呢?代码可能如下所示:{ { {
blocki
浏览 2
提问于2010-03-12
得票数 3
回答已采纳
2
回答
对
BlockingQueue
java
,Storm (分布式计算)
的
实现有问题吗?
、
、
这是我
的
input spout
的
代码片段,用于将元组发送到处理节点,以便在集群上进行流处理。问题是
BlockingQueue
抛出了InterruptedException。private SpoutOutputCollector collector;at <
浏览 0
提问于2012-07-05
得票数 1
回答已采纳
1
回答
从套接字
中
读取行,并将每行放入
BlockingQueue
、
、
有没有人可以用
Java
提供例子,或者建议实现一个类,它
异步
地从套接字读取行,并将每行放入一个
BlockingQueue
中
。假设套接字已连接,并且
BlockingQueue
和消费者已经存在。编辑:还有一件事,它需要能够
在
一段时间不活动后超时,并在命令后立即停止。非常感谢。
浏览 3
提问于2011-03-19
得票数 1
回答已采纳
2
回答
来自
Java
BlockingQueue
的
工作
项
的
并行有序处理
、
、
、
我有一个系统
的
一部分,它在工作线程
中
处理输入
项
的
BlockingQueue
,并将结果放在输出项
的
BlockingQueue
上,其中相关
的
代码(简化)如下所示: OutputObject b=doProcessing(a);是这段代码
浏览 6
提问于2021-02-03
得票数 2
1
回答
java
中
的
.NEt
异步
CTP
等效
项
、
、
、
在
java
中有没有类似于.NET
的
异步
ctp?如果不是,那么做类似的事情最接近
的
选择是什么?
浏览 1
提问于2011-10-07
得票数 0
5
回答
如何阻塞直到
BlockingQueue
为空?
、
、
我正在寻找一种方法来阻止直到一个
BlockingQueue
是空
的
。// Producer code
BlockingQueue
queue = new
Bloc
浏览 0
提问于2013-03-03
得票数 26
回答已采纳
1
回答
如果队列已满,则在添加元素时移除队列头
的
ArrayBlockingQueue
、
我正在尝试编写一个像ArrayBlockingQueue这样
的
简单队列,在这个队列
中
,如果队列已经满了,那么队列
的
头将被移除,同时添加一个元素。这个类应该只有下面的公共方法
在
队列尾部添加元素 private ArrayBlockingQueue<E>
block
浏览 0
提问于2017-12-18
得票数 1
回答已采纳
1
回答
如果队列已满,则在添加元素时移除队列头
的
ArrayBlockingQueue
、
、
我正在尝试编写一个像ArrayBlockingQueue这样
的
简单队列,在这个队列
中
,如果队列已经满了,那么队列
的
头将被移除,同时添加一个元素。这个类应该只有下面的公共方法 }
blocki
浏览 2
提问于2017-12-18
得票数 1
回答已采纳
3
回答
被
异步
通知具有可用项
的
BlockingQueue
、
、
我需要一个Object来
异步
通知,当一些
BlockingQueue
有一个项目给出。我
在
Javadoc和web上搜索了一个预制
的
解决方案,然后我得到了我
的
一个(可能是天真的)解决方案,如下所示: publiclistener.itemAvailable(item, cookie); }
浏览 0
提问于2011-09-06
得票数 12
回答已采纳
3
回答
有没有什么高效
的
BlockingQueue
实现允许组合条目?
、
、
是否有任何有效
的
(无需同步所有内容)
java
.util.concurrent.
BlockingQueue
实现允许组合条目?通过组合,我
的
意思是将传入
项
与队列
中
现有的“等于”
项
合并(如果有),否则
项
将像往常一样添加到末尾。
浏览 9
提问于2012-07-16
得票数 2
2
回答
在
java
中使用单独
的
线程读写文件。
、
我得到
的
问题是,即使我已经使用变量来控制线程一个接一个地执行,但是线程
的
执行仍然是不均匀
的
,即一个线程执行多次,然后控制转移。任何解决方案我都附上了代码。我对
java
是个新手,因为它只用于类分配,所以代码可能不是最优化
的
。
浏览 0
提问于2015-03-30
得票数 6
回答已采纳
1
回答
用于持久工作队列
的
Akka
、
我正在编写一个
在
Play 2.2.2
中
的
web应用程序,在用户更新一些状态后,我需要执行一些额外
的
昂贵处理。为了不妨碍用户,我想
异步
地安排这个处理。一种选择是将工作
项
放到
BlockingQueue
上,并让工作线程从工作线程
中
获取项目。然而,如果应用程序崩溃,我将失去挂起
的
项目。 阿克卡是否适合解决这个问题呢?
浏览 3
提问于2014-04-16
得票数 4
1
回答
到服务器
的
Okhttp流请求
、
、
、
我目前正在使用OkHttp向服务器发送语音请求。我记录并收集整个数据,然后将请求发送到server.Can。我使用OkHttp将数据请求流式传输到服务器,同时记录自己?
浏览 0
提问于2016-04-24
得票数 3
4
回答
ThreadPoolExecutor
的
队列行为可自定义为更喜欢创建新线程而不是队列?
、
、
如果运行
的
线程多于corePoolSize,但少于maximumPoolSize线程,则只有当队列已满时,才会创建新线程。是否有一种方法可以让执行器更倾向于新线程
的
创建,直到达到最大值,即使有超过核心大小
的
线程,然后开始排队?如果队列达到最大大小,则任务将被拒绝。如果超时设置
在
繁忙
的
突发处理后启动并移除线程到核心大小,那就太好了。我看到了选择队列以允许节流
的
原因;然而,这种自定义还将允许队列主要充当尚未运行
的
任务列表。
浏览 6
提问于2013-08-14
得票数 5
回答已采纳
2
回答
可变费率使用者
的
负载平衡队列
、
、
每个生产者推入一个队列,消费者从队列
中
消费。在任何时间点,都可以有一个或多个队列,每个使用者从单个队列
中
消费。但是生产者可以生产到任何队列。如果消费者慢下来,它就会不断地堆满消息。我试图提供一个框架,在这个框架
中
,我可以加载平衡
的
使用者,这样所有的使用者队列都有几乎相等
的
消息,而不管消费者
的
速度如何。示例:这里,队列Q1-Q3应该有几乎相等
的
消息,而不管C1-C3使用者
的
速率如何。我现在使用
的
默认策略是针对生产者
的
浏览 1
提问于2018-08-17
得票数 3
回答已采纳
3
回答
目标C to
Java
: NSOperationQueue?
、
但我被这行卡住了NSOperationQueue *queue = [[NSOperationQueue alloc] init]; 我知道这行代码构造了一个类NSOperationQueue
的
新实例但是NSOperationQueue
的
这个实例做了什么呢?有人能给我解释一下吗?由于我对
Java
比较熟悉,如果有人能推荐一段用
Java
编写
的
等效
代码,那将非常有帮助。
浏览 0
提问于2011-08-29
得票数 3
回答已采纳
1
回答
在
分布式环境
中
只使用一次Hazelcast队列
中
的
消息
、
、
、
我有一个和这篇文章类似的问题:消息
的
发布:我
在
两个不同
的
JVM
中
配置了相同
的
侦听器,如下所示: public Hazelca
浏览 3
提问于2016-07-08
得票数 0
1
回答
具有不同线程
中
的
读取器和写入器
的
Java
copy文件(使用
BlockingQueue
)
、
、
、
我正在尝试编写一个
java
程序来复制一个文件,读取器
在
一个线程
中
,写入器
在
另一个线程
中
。该程序不会显示任何错误,但复制
的
文件具有与原始文件不同
的
校验和。我找不到我
在
程序
中
犯
的
错误。当我尝试复制zip文件时,复制成功完成,但当我尝试解压缩复制
的
zip文件时,它显示zip文件已损坏。有人能帮我找出错误吗?import
java
.io.*; import
java
.ut
浏览 27
提问于2018-06-06
得票数 0
回答已采纳
1
回答
使用构造函数参数部署JAX-RS Servlet
、
、
我正在开发一个JAX servlet,它使用POST方法向队列
中
添加一个
项
。public class ServletResource extends Application { public void doPost(Item item) { }我
的
问题是,使用ResourceConf
浏览 4
提问于2016-04-19
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
在聊Java中的equals方法
Java反射机制在Spring IOC中的应用
cmd 中的中文乱码问题,java 程序在cmd中的退出
word2vec 在Java中的各种展现
Java编程语言在金融系统定制中的应用
热门
标签
更多标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
活动推荐
运营活动
广告
关闭
领券