腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
3
回答
在
JS
中
解决
异步
生产者
-
消费者
问题
、
、
我有一个数据
生产者
和一个数据
消费者
。
生产者
异步
生产,反过来,当有数据要消费时,我希望
消费者
异步
消费。我立即想到的
解决
这个
问题
的方法是使用某个队列对象,该对象具有可等待的shift/get、much like this async queue in the python standard 但是,我搜索了一下,找不到任何具有这种数据结构的
JS
库供我使用。
在
JS
中
解决<
浏览 148
提问于2019-06-27
得票数 4
回答已采纳
1
回答
异步
编程和反应编程
、
、
这个
问题
在我的脑海里已经大约一年了。事实上,
在
无障碍和非阻塞方面有什么区别吗?当我们
在
代码
中
调用阻塞部分时,它就变成了阻塞,这是同步的,同时也不会是非阻塞的。如果我们要创建除主线程之外的另一个线程来进行
异步
编程,并且必须返回一些值,那么我们必须在java
中
定义join()方法,而join()是阻塞操作,那么它实际上是
异步
的吗?我需要知道以下
问题
的答案 如果阻塞类似于同步,那么
异步
和非阻塞之间有什么区别。应该类似吗?如果不是,那为什
浏览 1
提问于2020-09-23
得票数 9
回答已采纳
1
回答
处理线程
中
执行产量返回函数的值
、
、
、
asyncEnumerator.MoveNextAsync()) T result = asyncEnum.Current; } 但我希望它继续得到下一个结果,而我正在做的东西,
在
时间循环我想也许有一个带有结果的队列,并在返回队列
中
的第一个结果的同时让线程来获得结果,但我无法让它工作起来。
浏览 1
提问于2017-06-30
得票数 2
回答已采纳
5
回答
Java:高性能消息传递(单
生产者
/单用户)
、
、
、
我最初问了这个
问题
,但我已经意识到我的
问题
不是关于一个短暂的真正循环。我想知道的是,
在
Java中进行高性能
异步
消息传递的正确方法是什么? 我想要做的.我有大约10,000名
消费者
,每个用户都在使用来自他们私人队列的信息。我有一个线程,它一个接一个地生成消息,并将它们放到正确的
消费者
队列
中
。我相信这个词是“单一
生产者
/单一
消费者
”,因为有一个
生产者
,而且每个
消费者
只在他们的私有队列上工作(多
浏览 8
提问于2010-07-29
得票数 7
1
回答
捕捉Spring兔
消费者
的异常
、
、
目前,当doJob抛出异常时,
生产者
将获得超时异常,并且该异常不会登录到服务器上的控制台上。 我试过用container.setErrorHandler,但没有结果。如何在
生产者
和
消费者
中
捕获例外情况?
浏览 3
提问于2021-02-11
得票数 0
回答已采纳
1
回答
在
生产者
和多
消费者
实现中等待所有
消费者
处于等待状态
、
、
、
、
问题
所在面向单一
消费者
的
解决
方案概念 让我们将
问题
简化为单个
消费者
的情况。该
解决
方案要求
生产者
等待一个额外的同步对象,
消费者
可以通过它的Monitor.Wait()入口自动发出信号。针对多个
消费者
的
解
浏览 24
提问于2019-11-07
得票数 2
2
回答
刷新连接时Weblogic JMS客户端线程停滞
、
、
、
我们已经观察到
在
刷新连接时会发生这种情况。
浏览 2
提问于2011-01-19
得票数 1
回答已采纳
1
回答
Activemq如何配置使用者侦听器(用Java)
、
、
编辑;EDIT2:,让我澄清一下这种复杂性。我有一个由两个基本独立部分组成的应用程序。换句话说,
生产者
是从计时器/cron执行的。现在的
问题
是
消费者</em
浏览 1
提问于2012-01-28
得票数 4
回答已采纳
1
回答
唤醒等待位对于多个
生产者
或
消费者
不起作用的示例
、
、
、
在
Andrew Tanenbaum的关于操作系统的书中,
在
关于
消费者
/
生产者
问题
一节
中
,他给出了一个关于系统的例子,该系统由一个
生产者
和一个
消费者
组成,
生产者
将数据块插入缓冲区,
消费者
将数据块从缓冲区
中
取出此外,还有一个计数器,它跟踪缓冲区
中
的数据块数量。当
消费者
验证计数器为零时,它将休眠。当
生产者
验证计数器为零,并将一些数据放入缓冲区
浏览 26
提问于2019-01-07
得票数 0
1
回答
JMS
中
的多线程
、
、
、
、
我需要编写一个多线程JMS
生产者
和一个多线程JMS
消费者
;我对使用JMS比较陌生,以前从未使用过多线程。我
在
API中看到,您可以使用
生产者
的完成侦听器和
消费者
的消息侦听器
异步
发送和接收消息。如果没有,那么如何编写多线程
生产者
和多线程
消费者
呢?
浏览 1
提问于2015-06-08
得票数 1
1
回答
用每个线程
中
的所有对象从多个thread读取java“队列”
、
、
是否有java.util.Queue的标准或第三方实现,允许我
在
多个线程
中
并发读取队列,但将所有对象传递给所有线程。 目标是对定期添加到队列
中
的消息进行多个并行处理。
浏览 6
提问于2019-01-30
得票数 1
2
回答
卡夫卡:如何从
消费者
那里得到回应?
我希望描述以下场景:我有一个node.
js
后端应用程序(它使用单个线程事件循环)。这是系统的总体架构:
生产者
-> Kafka ->
消费者
->数据库在这种情况下,
生产者
如何获得在数据库上操作的查询结果?
浏览 8
提问于2020-01-02
得票数 3
回答已采纳
1
回答
异步
订户ActiveMQ
、
、
我知道在
生产者
/
消费者
语义(队列作为目的地)
中
,
消费者
可以附加一个消息侦听器。因此,每当消息到来时,侦听器都会通过'onMessage()‘方法
异步
捕获它。我想知道
在
发布/订阅模式
中
是否存在这样的
异步
行为,这样订阅者就不需要调用'receive()‘方法来捕获已发布的消息。
浏览 2
提问于2013-10-03
得票数 0
2
回答
scala邮箱大小限制
、
、
、
、
我可以
在
Scala
中
设置演员邮箱的最大大小吗? 以
生产者
-
消费者
问题
为例。使用线程,我可以
在
缓冲区填满时阻塞
生产者
。我看到了几个用Scala编写的
生产者
-
消费者
示例,它们都使用了使用邮箱作为“缓冲区”的参与者。我是否可以设置邮箱大小,使
生产者
等待,直到
消费者
准备好?有没有其他优雅的
解决
方案来避免邮箱的无法控制的增长?
浏览 2
提问于2009-10-24
得票数 15
回答已采纳
3
回答
如何保持Mule流程直到JMS消耗完整个处理
、
、
、
我的骡子流中有JMS,其中
生产者
从缓存
中
读取记录,放入队列,
消费者
使用消息并进行进一步处理。以下是理解的流程。服务1(从文件读取数据) ->服务2(将每一行放在缓存
中
) -> JMS 3(从缓存逐行读取数据并放入队列)和用户从队列->服务4读取数据 在上面的流程
中
,
在
JMS组件
中
,一旦
生产者
将所有记录放在队列响应
中
,流就会变成
异步
,返回到客户端,表示流程已经完成,但是
消费者
仍
浏览 3
提问于2017-08-18
得票数 0
2
回答
将非平凡的代码转换为新的.NET
异步
模式-如何处理yield循环
、
、
、
基本模式是,给定的HTTP请求在内容流
中
返回一个数字结果,并在标头中返回指向下一组结果的指针。当从流
中
读取结果时,就会产生结果。我使用的是System.Net.Http库(以前是Microsoft.Net.Http),它在最新版本
中
删除了同步版本的HttpClient.Send和其他同步方法。新版本使用任务。已转换为
异步
模式的呼叫包括: HttpClient.Send、response.Context.ContentReadSteam。我已经清理了代码,以便显示重要的部分。
浏览 0
提问于2012-02-20
得票数 4
回答已采纳
1
回答
在
F#
中
,如何在不需要可变集合的情况下在
异步
计算
中
创建Async<unit>列表?
、
、
我有一个
在
F#中使用
生产者
/
消费者
模式的小程序。我想启动一个
生产者
,然后8个
消费者
,等待
生产者
,然后等待
消费者
和程序结束。async {let consumers2 = List.init 8 (fun _ -> async { return c
浏览 7
提问于2022-10-19
得票数 3
回答已采纳
3
回答
Java多线程
问题
-
消费者
/
生产者
模式
、
、
、
、
我试图
解决
这个
问题
,但它被证明是困难的。 我有两个线程,一个是
生产者
,另一个是
消费者
。都在不同的类
中
。这两个线程独立运行。
生产者
汇集了大约8-12个文件夹用于输入。然后,它会同时翻译所有文件,并将其放入名为“readyToLoad”的共享文件夹
中
。一旦
生产者
线程完成,
消费者
线程现在进入'readyToLoad‘文件夹,并开始处理翻译后的文档。现在的
问题
是,当
消费者
正在处理翻译的文档时,它不
浏览 0
提问于2013-07-19
得票数 1
1
回答
Kafka分区分配协议
、
、
、
我正在编写集成测试,以使用confluent-dotnet (包装librdkafka)来验证kafka
生产者
和
消费者
配置。
在
一个测试
中
,我想启动一个
消费者
,它将从现有分区的末尾启动,然后发布来自
生产者
的消息,并断言
消费者
只使用了一条消息。现在
消费者
的启动是
异步
的(即:如果你直接调用订阅然后发布,从最后开始的
消费者
将不会收到它)。
在
没有竞争条件的情况下编写此测试的合适方法是什么?一旦我完成了&quo
浏览 5
提问于2018-01-12
得票数 1
回答已采纳
1
回答
如何同步任务间共享数据的访问?
、
、
、
我
在
一些并行工作中使用.net内核和任务,基本上它就像两个
生产者
和一个使用者,两个任务将写入数据,使用者将读取它,
在
传统的.net代码
中
,这些都是由线程完成的,我可以使用Semaphore、Mutex或EventHandle来实现线程之间的同步,但是对于基于新任务的代码,我看到我不能再使用这些代码了,因为不能保证
异步
函数
在
等待之后
在
同一个线程上恢复,那么我应该如何在不同任务之间进行同步呢?
浏览 6
提问于2017-07-27
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
如何用Java编写代码解决生产者消费者问题?
微软在解决Windows 10中存在的Chrome问题
报告显示:37.3%的消费者在直播购物中遇到过问题
解决问题的关键:项目管理软件在项目问题处理中的作用
Vue3解决问题之Proxy在Vue中的作用
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券