腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(792)
视频
沙龙
1
回答
如
何在
另一个
计算
中
重用
队列
?
fs2
流
缩放
scala
、
queue
、
code-reuse
、
fs2
我正在尝试在下一个
队列
中
重用
队列
的结果 import cats.effect.
浏览 23
提问于2020-06-20
得票数 0
2
回答
用于处理数据
流
的消息
队列
rabbitmq
、
apache-kafka
、
mq
我有处理的输入数据
流
。每个
流
都是以大块数据发送的。我只能在处理完同一
流
i的第N块数据后,才能处理
流
I的N+1st数据块,因此,并行化可以通过一次处理多个流来实现,但我不能在多个工作人员上拆分一个
流
。一个
流
的块按顺序添加到
队列
中
(尽管可以同时添加来自多个
流
的块)。 大多数消息
队列
,
如
RabbitMQ,在一个
队列
上操作多个工作人员时保证有序传递。为了并行化,我可以为每个
流</e
浏览 4
提问于2015-11-30
得票数 1
1
回答
用于增长列表的scalaz
流
结构
scala
、
scalaz
、
akka-stream
、
scalaz-stream
def doSomething(a : A) : List[A]假设streams对此是合适的,那么请给我一些提示,说明我应该考虑哪些总体结构或类型来实现这一点?
浏览 2
提问于2015-12-07
得票数 0
回答已采纳
1
回答
如
何在
scala playframework / akka
中
设计缓冲的tcp发布者/订阅者
scala
、
sockets
、
tcp
、
playframework
、
akka
我们正在从基于python的环境迁移到scala play框架的过程
中
,我必须编写一个缓冲的发布者和订阅者,它将与
另一个
用python编写的系统进行接口。这里的目标是编写一个发布者,它将从缓冲区/
队列
中
获取消息,并通过tcp套接字将它们发送到服务器,并保持套接字打开,以便我们以后可以
重用
它。我们的旧python发布者创建了一个永远不会关闭的socket.socket(socket.AF_INET,socket.SOCK_STREAM)套接字,并与一个调度器一起工作,从
队列
<em
浏览 3
提问于2016-05-07
得票数 1
1
回答
使用多处理和
队列
处理无休止数据
流
python
、
python-2.7
、
python-multiprocessing
我想使用Python2.7多处理包来操作一个没完没了的数据
流
。子进程将通过TCP/IP或UDP数据包不断接收数据,并立即将数据放在multiprocessing.Queue
中
。我知道我可以把()和get()放在
队列
上,但是我如
何在
没有( a)备份
队列
和b)保持threadsafe的情况下创建数据片段呢? 我认为我必须不断地使用
另一个
子进程从
队列
中
获取(),以防止
队列
满。然后,我必须将数据存储在
另一个
数据结构
浏览 1
提问于2017-01-31
得票数 1
2
回答
WCF - C#服务应该不断地发送结果。
c#
、
wcf
、
streaming
(考虑到结果是自定义对象,所以它与文件
流
不完全相同)情况: 解(A) -慢非平行方式: 客户端向一个服务发送输入。--这意味着所有服务都在任务上并行工作,当客户端从所有服务应答
中
得到1000个结果的总和时,它将发送停止信号。如
何在
C#
中
实现客户机/服务体系结构,其中服务不断发送结果,而不
浏览 9
提问于2011-06-11
得票数 3
回答已采纳
1
回答
如
何在
运行Azure
流
分析查询时获取系统时间
azure
、
azure-stream-analytics
在应用程序
中
,有一组事件到达事件中心,作为
流
分析的一部分,我有一组要求,其中之一是确定某些记录是否在最后x分钟内到达事件中心。我在消息中有一个时间戳,它告诉我消息的有效时间,但是为了
计算
消息的有效时间和now()之间的滞后,在运行查询时我需要知道当前的时间戳。我尝试了System.Timestamp,但它给出了值"1970-01-01T12:01:01.0010000Z“ 如
何
浏览 2
提问于2018-05-08
得票数 1
回答已采纳
6
回答
如
何在
java
中
做演员(erlang)?
java
、
erlang
、
concurrency
、
actor
我在Java
中
从事金融应用程序的工作,要正确地处理并发是一件很痛苦的事情。Erlang和角色模型应该非常适合大规模并发应用程序,但我不知道如
何在
Java
中
做到这一点。比方说,我需要处理三到四个不同的事件,比如从市场数据提要、订单/交易提要
计算
一些数字,并“输出”这些数据的一些派生数据。大多数情况下,这些事件或数据
流
需要按顺序处理(至少对于某些key...for示例,必须按顺序处理特定符号的所有顺序,但相对于不相关的符号是并行处理的) 我用改变状态的方法创建了一个普通的Java对象。我没有让这些方
浏览 0
提问于2009-04-27
得票数 5
回答已采纳
2
回答
混合音频:添加音频缓冲区
c++
、
c
、
audio
、
audiobuffer
frameOutput.p_data[i] = frameInput1.p_data[i] + frameInput2.p_data[i]; } 我用相同的样本创建了一个音频缓冲区,并为数据数组
中
的每个样本添加了输入帧
浏览 43
提问于2021-09-03
得票数 0
2
回答
完成所有工作后终止现有池
groovy
、
gpars
我们目前有一段代码包装在一个Thread.start {}块
中
。这样就可以将消息发送到后台的消息
队列
中
,而不会阻止用户的请求。我们最近遇到的一个问题是对于大块的工作,用户可以执行
另一个
操作,这将导致这个块再次执行。由于它是线程的,第二批消息有可能在第一批导致数据损坏之前被发送。我希望将此过程更改为使用gpars作为
队列
流
工作。我见过创建池的例子,
如
或 def pool = new ForkJoinPo
浏览 4
提问于2015-05-11
得票数 1
回答已采纳
3
回答
是否有一个分布式的数据处理管道框架,或者组织一个好的方法?
mapreduce
、
go
、
distributed-computing
我正在设计一个应用程序,它需要一组需要异步使用和在特定
流
中生成数据的分布式处理工作人员。例如: 运行实际工作人员(goroutines或
浏览 0
提问于2013-03-16
得票数 6
1
回答
在
另一个
pictureBox
中
通过悬停光标c#在部分pictureBox中放大显示
c#
、
image
、
picturebox
我希望能够将光标悬停在图像上,并在
另一个
picturebox
中
显示光标周围的
缩放
区域。我也想添加一个十字,而不是鼠标指针。到目前为止,我发现的唯一解决办法是: 它能做我想做的事,但是我不能让它工作。更具体地说,在picZoom
中
什么也没有出现。在本例
中
,图像被加载,而在我的示例
中
,则显示一个视频
流
。这可能就是我不让它开始工作的原因。我对c#比较陌生,没有完全理解这个例子。假设我有picBox,我在那里接收视频
流
。如
何在
picBox<
浏览 8
提问于2022-03-03
得票数 0
回答已采纳
2
回答
SNS通知调度
parse-platform
、
amazon-sns
、
moengage
是否有可能通过SNS安排我们的推送通知(在一天
中
的某个特定时间发送)?
浏览 2
提问于2016-06-01
得票数 2
回答已采纳
2
回答
在node.js web应用程序
中
避免竞争条件
node.js
、
design-patterns
我想知道设计这样一个web服务的方法是什么:我使用node.js已经有几个星期了,我很惊讶没有找到展示这种用例的例子。
浏览 4
提问于2014-06-10
得票数 1
回答已采纳
2
回答
AMQP经纪人和发生-在担保之前
design
、
architecture
、
concurrency
、
message-queue
、
microservices
我试图弄清楚如何将AMQP代理(
如
RabbitMQ )集成到我们的体系结构
中
。这应该允许在未来水平上轻松地进行
缩放
。说你有:但是,如果用户“立即”发起另一次撤回会发生什么呢?相应的消息可能会被
另一个
工作人员接收,从而导致两个工作人员同时处理同一个银行帐户。你如
何在
工人之间进行同步,以保证发生之前的关系?如何防止一个工人在同一个
浏览 0
提问于2016-06-24
得票数 2
回答已采纳
3
回答
基于值的字典顶部k键的有效跟踪
python
、
sorting
、
dictionary
、
scalability
我尝试过在每次更新后(
如
中所描述)从字典
中
创建排序列表的天真方法,但是这非常昂贵,而且不
缩放
。
计算
来自无限数据
流
的单词频率。在任何给定的时刻,程序可能会被要求报告一个单词是否位于当前的 top-k最频繁的值
中
。c.most_common(1)', 'from __main__ import c', number=1)>>> sum(c.values())
计
浏览 5
提问于2013-03-15
得票数 4
回答已采纳
1
回答
在MVC
中
,背景任务的代码属于哪里?
model-view-controller
、
asp.net-mvc-2
、
semantics
、
project-organization
视图(HTML )内容(静态contentScripts (JavaScript)App_Data (数据库文件)) 这很好,但如果我想让代码与浏览器请求分开运行--例如,一个请求可能运行一些代码,但在
另一个
线程
中
在我的例子
中
,代码可以处理数据--生成数据、清理数据等等--这让我觉得它应该在模型
中
运行。但它并不是真正的“模型”数据,它只是在后台工作。这类事情有语义的地方吗?
浏览 8
提问于2010-12-18
得票数 1
回答已采纳
1
回答
SQS或Kinesis哪一种适合排队?
amazon-web-services
、
api
、
amazon-sqs
、
amazon-kinesis
当大量请求出现时,我希望将请求数据存储在某些
队列
中
。并读取一组请求(即20)并进行批处理。怎样才是最理想的方法呢?使用SQS,或运动。我完全糊涂了。
浏览 3
提问于2019-02-26
得票数 2
回答已采纳
2
回答
为什么要在公共的叉连接池线程之外执行叉连接任务?
java
、
java.util.concurrent
、
fork-join
、
forkjoinpool
ForkJoinPool.commonPool-worker-1,5,main]Thread[ForkJoinPool.commonPool-worker-1,5,main] 为什么某些任务在主线程
中
运行
浏览 5
提问于2017-08-26
得票数 3
回答已采纳
3
回答
将
fs2
流
输出拆分为两个文件
scala
、
fs2
、
cats-effect
我刚刚从
fs2
流
开始我的冒险。我想要实现的是读取一个文件(这是我使用
fs2
的原因),转换它并将结果写入两个不同的文件(基于某个谓词)。最明显的解决方案是有两个具有不同过滤器的
流
,但是效率很低(会有两条通道)。
浏览 9
提问于2020-10-03
得票数 5
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
松散耦合深度学习Serving的优势和部署案例
“技术架构”TOGAF建模:处理图/部署图
事件驱动微服务体系架构
源码分析:探索 Java ForkJoinPool:并发任务处理的原理与实践解析
学习 Java 中最困难的部分以及如何克服它们
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
云直播
活动推荐
运营活动
广告
关闭
领券