腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如何
使用
concurrent.futures.ProcessPoolExecutor
在
进程
之间
传递
消息
/
信息
python
、
multiprocessing
我正在尝试
在
我的
进程
之间
传递
消息
。我有一个
进程
,它是服务器的客户端。我希望其他
进程
将
信息
传递
给客户端,然后再将其
传递
给服务器。把服务器想象成一个数据记录器。我正在
使用
concurrent.futures.ProcessPoolExecutor
。这些
进程
在
while True中连续工作。 理解
如何
连接
进程
的任何提
浏览 69
提问于2020-05-03
得票数 0
1
回答
在
多个python
进程
之间
共享RabbitMQ通道
python
、
rabbitmq
、
multiprocessing
、
pika
我希望跨多个python
进程
共享BlockingChannel。以便从其他python
进程
发送basic_ack。我尝试过
使用
pickle转储,但它允许转储通道,并
使用
折叠代码提供错误can't pickle select.epoll objects目标: 目
浏览 0
提问于2019-01-17
得票数 2
回答已采纳
1
回答
是否将存储
在
threading.local中的数据
传递
给以ProcessPoolExecutor开头的子
进程
?
python-3.x
、
multithreading
、
multiprocessing
如果我
在
主
进程
中
使用
threading.local()来存储数据,它会被复制到
使用
concurrent.futures.ProcessPoolExecutor
启动的
进程
中吗 thread-local-data的文档表明线程本地数据不在线程
之间
共享。但是,它没有提到它是否/
如何
在不同
进程
中的线程
之间
共享。 从逻辑上讲,我认为这个问题的答案是否定的。但是我还没有找到关于这个用例的明确文档。
浏览 8
提问于2020-03-23
得票数 0
回答已采纳
2
回答
在
Python中的多个
进程
之间
共享DB客户端?
python
、
python-3.x
、
concurrent.futures
我的python应用程序
使用
concurrent.futures.ProcessPoolExecutor
和5个工作人员,每个
进程
进行多个数据库查询。
在
选择将每个
进程
赋予自己的db客户端
之间
,还是让所有
进程
共享一个客户端,哪个
进程
被认为是更安全和常规的?
浏览 3
提问于2021-11-21
得票数 0
回答已采纳
3
回答
使用
消息
队列
在
进程
之间
传递
消息
c++
、
posix
我有一个
使用
消息
队列
在
两个
进程
之间
进行通信的需求。一个
进程
向另一个
进程
发送请求,另一个
进程
发送响应。我认为上面设计的问题是,随着文件名legth的改变,指向数据的char*指针是不同的,但结构的大小始终是恒定的,所以接收器没有接收到所有的数据,并且接收器
在
访问有没有其他方法可以
使用
消息
队列
浏览 2
提问于2010-11-25
得票数 1
回答已采纳
2
回答
当多个子
进程
使用
`queue.Queue`访问时,`
concurrent.futures.ProcessPoolExecutor
`线程安全吗?
python
、
python-3.x
、
multithreading
我一直
在
大量
使用
queue.Queue,在这种情况下,我执行多个线程,例如
使用
concurrent.futures.ThreadPoolExecutor。我从博客中读到,queue.Queue应该是线程安全的,但这是否意味着它是线程安全的,假设Python解释器一次只执行一个线程(GIL),或者
在
使用
multiprocessing的情况下也是线程安全的--
在
使用
multiprocessing的情况下--通过
使用
子
进程
而不是线程来执行G
浏览 3
提问于2020-04-20
得票数 1
回答已采纳
1
回答
码头与主机系统的
进程
间通信
python
、
apache
、
multiprocessing
这应该可以通过网络
使用
HTTP访问。由于我希望Apache充当服务器,所以我
使用
python脚本将接收到的数据发送到我的程序,
使用
python multiprocessing.connection。现在,当Apache
在
主机系统中时,我想将ML部件放入一个坞容器中。在这种情况下,我将
如何
沟通?
浏览 3
提问于2016-06-14
得票数 0
回答已采纳
1
回答
ProcessPool中的Python实例计数器
python
、
multiprocessing
我很难找到实现以下内容的正确方法:我
在
Python3中有一个类,为此我保留了一个实例计数器。
使用
concurrent.futures.ProcessPoolExecutor
,我提交了几个
使用
该类的任务。我认为,由于任务
在
单独的
进程
中运行,它们
之间
将不存在共享状态,但似乎我错了,因为
在
它们
之间
共享了这个实例计数器。from node{self.id}' instance = A()
浏览 4
提问于2022-07-29
得票数 0
回答已采纳
2
回答
Erlang在其收件箱中
使用
什么数据结构?
data-structures
、
erlang
Erlang
使用
消息
传递
在
进程
之间
进行通信。它是
如何
处理并发传入
消息
的?
使用
了什么数据结构?
浏览 1
提问于2017-01-02
得票数 1
1
回答
Node.js聊天应用程序和群集
javascript
、
node.js
、
socket.io
、
cluster-computing
现在,每个子集群
在
同一端口上都有socket.io连接。但是我应该在哪里将所有套接字(用户)组合成对,在哪个子群集中?一些套接字
在
一个集群中,一些套接字
在
另一个集群中。
浏览 0
提问于2012-09-15
得票数 0
回答已采纳
1
回答
为什么
concurrent.futures.ProcessPoolExecutor
的性能很低?
python-3.x
、
threadpool
、
python-multithreading
、
concurrent.futures
、
process-pool
我试图利用
concurrent.futures.ProcessPoolExecutor
在
Python3中并行处理一个大型矩阵。f是我的并发函数,它接受一行self.matrix并在其上应用与CPU绑定的
进程
。最后,fetch_multiple是一个并行运行多个f实例并返回结果的函数。我认为问题在于self.matrix的大对象和
进程
之间
的行向量
传递
。我该
如何
解决这个问题?
浏览 1
提问于2017-08-31
得票数 1
回答已采纳
3
回答
Apache Storm和LMAX Disruptor
之间
的区别
apache-storm
、
disruptor-pattern
Apache Storm和LMAX Disruptor
之间
的对比差异是什么?两者都在一起解决不同的问题吗?如果有,是什么?虽然LMAX Disruptor用于在线程
之间
传递
消息
,但对数据执行某些处理的事件被链接在一起(如树、菱形、三角形、简单序列)。同样,风暴的Spouts与多个对数据执行某些处理的Bolts链接在一起,数据从一个螺栓
传递
到另一个,直到没有更多的螺栓。这是不是类似于LMAX Disruptor,还是我看错了?除此之外,Apache Storm是否也可以像LMAX Disruptor那样<e
浏览 3
提问于2015-03-19
得票数 2
1
回答
如何
在
使用
并发期货时共享状态
python
、
python-3.x
、
python-multiprocessing
、
python-multithreading
我知道,
使用
传统的多处理库,我可以声明一个值,并在
进程
之间
共享状态。 data_pools = get_data() with
concurrent.futures.ProcessPoolExecutor
在前面的库中,我可能
使
浏览 0
提问于2019-05-06
得票数 6
回答已采纳
1
回答
SeedSequence.spawn和SeedSequence.generate_state
之间
的区别是什么
numpy
、
random
我正在尝试
使用
numpy的SeedSequence
在
不同的
进程
中播种RNG。(1) with
concurrent.futures.ProcessPoolExecutor
ss.generate_state(num_repeats)))) ss = np.random.SeedSequence(2437992547049244410500487
浏览 8
提问于2021-07-29
得票数 0
回答已采纳
4
回答
角色模型是否仅限于特定的语言?
scala
、
architecture
、
erlang
、
actor
根据我到目前为止收集到的少量
信息
,角色模型将处理分解为通过
传递
消息
相互通信的组件。通常,这些
进程
是不可变的。 但是,这些特性是特定于语言的,还是
在
体系结构级别上更多?更具体地说,您不能在几乎任何语言中实现相同的角色模型,并
使用
某种形式的
消息
队列
在
工作
进程
之间
传递
消息
吗?(例如,
使用
类似的内容)。或者像Erlang和Scala这样的语言只是透明地做这件事并且
浏览 0
提问于2012-04-26
得票数 9
回答已采纳
3
回答
在
Python中保持多个无限
进程
活动
python
、
multiprocessing
在
我的应用程序中,我有4个
使用
python多处理的函数的
进程
,他们从一个
消息
队列中消耗这些
进程
,并对它们进行一些计算。例如,如下所示: def run(): [executor.submit
浏览 44
提问于2020-12-30
得票数 0
3
回答
在
进程
之间
传递
消息
linux
、
multithreading
、
process
我需要编写一个简单的函数,
在
linux中执行以下操作:
浏览 5
提问于2013-05-22
得票数 2
1
回答
需要帮助设计应用程序的体系结构和
使用
Docker的部署策略
docker
、
deployment
、
rabbitmq
、
cloud
、
camunda
,同样的,FileConverter工作流也
使用
调用活动任务的子流程。全局
进程
是长时间运行的
进程
,因此每当子
进程
启动时,它都会在特定的兔子队列中发送一条
消息
,并等待特定兔子队列中的响应
使用
接收任务恢复子
进程
。我们已经
在
springs中创建了一个兔子队列listner,它将侦听各个工作流的特定队列,每当
消息
在这些队列中被删除时,工作流就会被调用。
在
开发过程中,这三个工作流都将在单个tomcat实例中进行部署和测试,因此
浏览 0
提问于2017-07-18
得票数 1
1
回答
微服务AMQP等价物
microservices
是否存在用于微服务
之间
通信的无状态服务的AMQP等效内部服务结构?首先,这个应用程序将把微服务锁定在API网关后面。从这文章中,我了解到REST接口对于向公众公开您的服务非常有用,同时
使用
AMQP ()从数据库或其他服务中请求服务。从这文章中,我了解到AMQP是服务间通信的首选方法,因为它是完全异步的。因此,基于此,我正在寻找一个实现,其中我的微服务有一个REST接口,并将
使用
AMQP查询通过REST接口请求的数据。由于我正在
使用
Service和重新发明轮子是浪费时间,我开始好奇
浏览 0
提问于2017-07-10
得票数 1
回答已采纳
1
回答
基于websockets的节点聚类
node.js
、
sockets
、
websocket
、
socket.io
、
node-cluster
现在,客户端
在
各种游戏
之间
进行选择(每个节点
进程
处理一个游戏)。 是否可以将套接字
传递
给节点
进程
,从而不需要打开新连接?如果我只
使用
一个连接(
在
主
进程
中)并将用户
消息
传递
给相应的节点
进程
并将<
浏览 1
提问于2016-03-24
得票数 5
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
RPC 服务器之多进程描述符传递高阶模型
GO语言的并发Concurrency:Goroutine与通信机制Channel
仅用3行Python代码即可让数据脚本提升4倍的速度!
像Apache Storm一样简单的分布式图计算
socket 通信必知必会|Python 标准库
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券