Python -在进程之间共享套接字
Python中，在进程之间共享套接字可以使用multiprocessing模块中的Pipe()函数或者Queue()函数。
- Pipe()函数：Pipe()函数返回一个由两个连接的套接字对象组成的元组，可以在父进程和子进程之间进行双向通信。一个套接字用于发送数据，另一个套接字用于接收数据。
示例代码：
from multiprocessing import Process, Pipe
def child(conn):
conn.send("Hello from child process!")
data = conn.recv()
print("Child received:", data)
conn.close()
parent_conn, child_conn = Pipe()
p = Process(target=child, args=(child_conn,))
p.start()
print("Parent received:", parent_conn.recv())
parent_conn.send("Hello from parent process!")
p.join()推荐的腾讯云相关产品：无
- Queue()函数：Queue()函数返回一个进程安全的队列对象，可以在多个进程之间进行数据传递。可以使用put()方法将数据放入队列，使用get()方法从队列中获取数据。
示例代码：
from multiprocessing import Process, Queue
def child(q):
q.put("Hello from child process!")
data = q.get()
print("Child received:", data)
q = Queue()
p = Process(target=child, args=(q,))
p.start()
print("Parent received:", q.get())
q.put("Hello from parent process!")
p.join()推荐的腾讯云相关产品：无
以上是Python中在进程之间共享套接字的两种方法。使用这些方法可以实现进程间的通信，方便数据的传递和共享。
相关·内容
1回答
Python多处理管道recv() doc不清楚或者我错过了什么吗？
python、multiprocessing、pipe
最近，我一直在学习如何使用Python多处理模块，并阅读官方文档。在中，有一个关于使用管道交换数据的简单示例。
在中，引用了这样的说法：“如果没有什么可接收的，并且另一端关闭了，那么就提出EOFError。”
因此，我修改了示例如下所示。这应该触发一个EOFError异常:没有发送，发送端被关闭。
经修订的守则：
from multiprocessing import Process, Pipe
def f(conn):
#conn.send([42, None, 'hello'])
conn.close()
if __name__ == '__ma
浏览 2提问于2011-12-21得票数 7
回答已采纳
3回答
使用python更改线程中的对象值
python、multiprocessing
我对Python非常陌生，因此可能会问一个简单的问题。
我正在用Python编写一个多进程代码：
from multiprocessing import Process
from multiprocessing import Queue
class myClass(object):
def __init__(self):
self.__i = 0
self.__name = 'rob'
return
def target_func(self, name, q):
self.__name = n
浏览 2提问于2013-08-14得票数 1
回答已采纳
1回答
同时将更改计数器整型变量发送到另一个python脚本
python、variables、multiprocessing
我有两个python脚本，script1.py和script2.py。一个是计数器，它独立地递增into，而script2.py是每5秒获取一次into的值，输入到script2.py中。我试着从下面的帖子中逐字地使用多处理来做到这一点。 Passing data between separately running Python scripts 我为script1申请了While True函数。这是我的尝试，但我不认为我理解了一般的想法，我得到了各种各样的错误，因为我是python的新手，我错过了一些细节。 script1.py： from multiprocessing import P
浏览 8提问于2020-09-12得票数 0
回答已采纳
1回答
Python多进程-捕获SIGINT/SIGTERM并优雅地退出
python、windows、multiprocessing、sigint、sigterm
我有两个python脚本，我希望它们能够相互通信。具体来说，我希望脚本Communication.py发送一个数组到脚本Process.py，如果后者需要的话。我使用了模块multiprocessing.Process和multiprocessing.Pipe来使其工作。我的代码可以工作，但我想优雅地处理SIGINT和SIGTERM，我尝试了以下方法，但它没有优雅地退出：
Process.py
from multiprocessing import Process, Pipe
from Communication import arraySender
import time
import si
浏览 45提问于2022-10-08得票数 0
回答已采纳
2回答
python中的生产者使用者锁定get
python、multithreading、python-3.x
我正努力在Python3中建立一个生产者消费者队列。我无法让我的消费者醒来：
from multiprocessing import Process, Queue
import time
def consumer(q):
while(True):
data=q.get()
if (data[0]==False):
print("Killing")
return
print((data[1]))
time.
浏览 5提问于2015-06-16得票数 1
回答已采纳
1回答
在多处理进程中使用队列是否使用酸洗？
multithreading、pytorch、python-multiprocessing、pytorch-dataloader
请考虑中的以下示例。multiprocessing.Process是否使用序列化(泡菜)将项放入共享队列？
from multiprocessing import Process, Queue
def f(q):
q.put([42, None, 'hello'])
if __name__ == '__main__':
q = Queue()
p = Process(target=f, args=(q,))
p.start()
print(q.get()) # prints "[42, None,
浏览 13提问于2022-07-20得票数 1
回答已采纳
3回答
Python:多处理和请求
python、python-2.7
下面是我运行以使用多处理的代码片段，它并行地触发HTTP请求。在控制台上运行后，它在"requests.get(url)“处挂起，既没有继续进行，也没有抛出错误。
def echo_100(q):
...
print "before"
r = requests.get(url)
print "after"
...
q.put(r)
q = multiprocessing.Queue()
p = multiprocessing.Process(target=echo_100,args=(q))
p.star
浏览 2提问于2015-05-26得票数 6
2回答
使用管道的Python多进程非阻塞通信
python、multiprocessing、pipe
是否有可能以非阻塞的方式使用管道接收进程间的通信？
考虑以下代码：
from multiprocessing import Process, Pipe
import time
def f(conn):
time.sleep(3)
conn.send('Done')
conn.close()
if __name__ == '__main__':
parent_conn, child_conn = Pipe()
p = Process(target=f, args=(child_conn,))
p.start()
浏览 1提问于2018-04-25得票数 4
回答已采纳
1回答
进程不会在python中启动
python、queue、multiprocessing
我正在尝试制作一个简单的python脚本的原型，以学习如何使用多处理。我想在后台有一个进程，它将生成虚拟数据，并将其放入队列中，而用户仍然能够键入命令。
下面是我的代码：
from multiprocessing import Process
from multiprocessing import Queue
import random
import os
global run
def waitForStart(q):
global run
print("(h for help)")
while run == 0:
response
浏览 0提问于2017-08-12得票数 0
1回答
可实时处理的python多处理(队列和管道)
python、parallel-processing、python-multiprocessing
我有点困惑于测试多处理模块。
让我们模拟一个数字计时器。代码看起来应该是：
start=datetime.now()
while True:
now=datetime.now()
delta=now-start
s = delta.seconds + delta.microseconds/1E6
print s
time.sleep(1)
它正确地返回：
8e-06
1.001072
2.00221
3.003353
4.004416
...
现在，我想使用管道从虚拟外部数字时钟设备中读取时钟：
def ask_timer(conn):
sta
浏览 2提问于2015-10-08得票数 3
1回答
多处理队列-子进程有时会被卡住，而不会收获。
python、multiprocessing
首先，如果标题有点奇怪，我很抱歉，但我实在想不出如何把我所面临的问题写进一行。
所以我有下面的代码
import time
from multiprocessing import Process, current_process, Manager
from multiprocessing import JoinableQueue as Queue
# from threading import Thread, current_thread
# from queue import Queue
def checker(q):
count = 0
while True:
浏览 1提问于2019-02-04得票数 0
回答已采纳
1回答
重复产卵相同的过程
python、multiprocessing
请帮我弄清楚这件事。
我遇到的问题是，process 1的内部有一个for循环，数据被收集起来，然后我需要生成一个进程来分析它。
这段代码只创建每个进程一次，如何对每个数据()循环重复进程2？提亚
from multiprocessing import Process, Queue
def data(q):
dosmth()
for i in range(5):
fetch_data()
q.put('data has been added')
def analysis(q):
msg = q.get()
浏览 1提问于2016-01-21得票数 0
回答已采纳
2回答
通过全局命名空间vs作为函数参数共享同步对象
python、python-3.x、multiprocessing
如果我需要共享一个multiprocessing.Queue或multiprocessing.Manager (或任何其他同步原语)，那么通过在全局(模块)级别定义它们与将它们作为参数传递给在不同进程中执行的函数有什么不同吗？
例如，这里有三种可能的方法，我可以想象队列可以被共享：
# works fine on both Windows and Linux
from multiprocessing import Process, Queue
def f(q):
q.put([42, None, 'hello'])
def main():
q = Queue
浏览 4提问于2017-03-11得票数 1
回答已采纳
2回答
无法使用multiprocessing.Process() Python交换子进程的对象/超时
python、timeout、python-multiprocessing
从主进程开始，我将使用multiprocessing.Process生成一个新的进程。
我的目标是在子进程中执行一个繁重的CPU密集型任务，如果任务要花太长时间(使用timeout_in变量)才能完成，那么就用一个响应来终止它，否则计算，然后在子进程中从这个任务中得到结果。
如果需要太长时间，我可以终止，但是在没有强制终止子进程的情况下，我无法获得对象(result)。
from multiprocessing import Process,Queue
def do_threading(function,argument, timeout_in=1):
# Making a que
浏览 2提问于2015-05-13得票数 2
回答已采纳
2回答
如何实现进程间的实时通信？
python
我有两个进程，其中一个进程的数据必须与另一个进程通信。我写了一个基本的队列，以便进行实时通信，但它并没有达到这个目的。
以下是示例代码：
from multiprocessing import Process , Pipe , Queue
a , b = Pipe()
q = Queue()
def f(name):
i = 0
while i < 4:
q.put(i)
i += 1
def t():
print q.get()
if __name__ == '__main__':
p = Process(target=f, args=(&#
浏览 2提问于2011-05-02得票数 0
回答已采纳
2回答
Python在单独的进程中运行。我可以统一包装器函数吗
python、multiprocessing、wrapper
我是Python的新手，我想知道如何在语法上更有效地实现以下问题。我有函数f1，f2 ...fN这些函数是派生新进程的包装器(目标是_f1、_f2、.._fN)，传递其参数(arg1，arg2，...)到子进程并接收返回值。
使用这样的代码，我希望模块功能在不同的进程中执行，而不是在调用者(模块的用户)进程中执行。
函数f1、f2、...fN (分别为_f1、f2、... _fN)可能有不同的原型。
in a module
def _f1(arg1, arg2, ... argn, connection):
...
connection.send(return_value)
浏览 3提问于2014-10-20得票数 0
2回答
在使用multiprocessing.Queue时如何理解multiprocessing.Pool？
python、multiprocessing
为什么我不能把process放在Pool中，变成Queue
在这里，我的代码在使用Pool时工作，可以获得Test实例属性。
from multiprocessing import Pool
from multiprocessing import Queue
class Test(object):
def __init__(self, num):
self.num = num
if __name__ == '__main__':
p = Pool()
procs = []
for i in range(5):
浏览 0提问于2018-12-24得票数 0
回答已采纳
1回答
Python，让一个进程在后台运行并从主线程获取状态
python、multiprocessing
这是一个新手问题，我从来没有在Python中做过太多的工作。我需要有一个主进程运行并做一些事情，而后台进程执行其他计算并将结果保存到一个变量中。当主线程需要时，它应该能够读取存储在变量中的最后一个值:之前存储的每个值都会被忘记。假设后台进程正在计数:我想知道它在这一时刻是多少。下面是一个虚拟代码：
from multiprocessing import Process, Pipe
import os
import time
def f(queue):
a=0
while True:
a=a+1
child_conn.send(a)
浏览 13提问于2016-08-06得票数 2
回答已采纳
2回答
队列不为空时queue.get()超时
python、python-multiprocessing
我试图实现一个多处理队列，该队列是从第二个进程函数中填充的。通过测试这个函数，它显示多进程工作正常，并且队列似乎正在填充。通过打印数据，确认了worker函数中的数据是正确的。此外，我已经证实，在运行queue.put(ret)后，qsize会增加。但是，运行queue.get()会导致代码挂起和超时。这似乎与我正在放入队列中的数据有关，因为我的worker函数中的一个简单的queue.put("hello")工作正常。知道为什么会发生这种事吗？我已附上有关守则如下。
def worker(queue):
print("Running worker")
浏览 12提问于2022-08-26得票数 1
2回答
多处理队列-为什么内存消耗增加？
python、python-2.7、queue、multiprocessing、python-multiprocessing
以下脚本生成100个大小为100000的随机字典，将每个元组(键、值)输入队列，同时一个单独的进程从队列中读取：
import multiprocessing as mp
import numpy.random as nr
def get_random_dict(_dummy):
return dict((k, v) for k, v in enumerate(nr.randint(pow(10, 9), pow(10, 10), pow(10, 5))))
def consumer(q):
for (k, v) in iter(q.get, 'STOP'
浏览 0提问于2014-11-07得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
活动推荐
腾讯云开发者
