python多進程間通信代碼實例

這篇文章主要介紹了python多進程間通信代碼實例,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下

這里使用pipe代碼如下：

import time

from multiprocessing import Process

import multiprocessing

class D:

@staticmethod

def test(pipe):

while True:

for i in range(10):

pipe.send(i)

time.sleep(2)

@staticmethod

def test2(pipe):

while True:　　　　　　　print('test2 value:%s' % pipe.recv())

time.sleep(2)

if __name__ == '__main__':

pipe = multiprocessing.Pipe()

p = Process(target=D.test2,args=(pipe[0],))

p2 = Process(target=D.test,args=(pipe[1],))

p.start()

p2.start()

執行后的效果：

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持我們。

時間： 2019-09-30

queue和pipe的區別: pipe用來在兩個進程間通信.queue用來在多個進程間實現通信. 此兩種方法為所有系統多進程通信的基本方法,幾乎所有的語言都支持此兩種方法. 1)Queue & JoinableQueue queue用來在進程間傳遞消息,任何可以pickle-able的對象都可以在加入到queue. multiprocessing.JoinableQueue 是 Queue的子類,增加了task_done()和join()方法. task_done()用來告訴queue一個tas

本文實例講述了python執行子進程實現進程間通信的方法.分享給大家供大家參考.具體實現方法如下: a.py: import subprocess, time subproc = subprocess.Popen(['c:\python31\python.exe', 'c:/b.py'], stdin=subprocess.PIPE, shell=True) time.sleep(0.5) print('start') subproc.stdin.write('data\n') subproc.

本文實例講解了python實現兩個程序之間通信的方法,具體方法如下: 該實例采用socket實現,與socket網絡編程不一樣的是socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)的第一個參數是socket.AF_UNIX 而不是 socket.AF_INET 例中兩個python程序 s.py/c.py 要先運行s.py 基于fedora13/python2.6測試,成功實現! s.py代碼如下: #!/usr/bin/env python im

python中的多線程其實并不是真正的多線程,如果想要充分地使用多核CPU的資源,在python中大部分情況需要使用多進程.Python提供了非常好用的多進程包multiprocessing,只需要定義一個函數,Python會完成其他所有事情.借助這個包,可以輕松完成從單進程到并發執行的轉換.multiprocessing支持子進程.通信和共享數據.執行不同形式的同步,提供了Process.Queue.Pipe.Lock等組件. multiprocessing.Queue() 以Queue為例,

Python中的多線程其實并不是真正的多線程,如果想要充分地使用多核CPU的資源,在python中大部分情況需要使用多進程.Python提供了非常好用的多進程包multiprocessing,只需要定義一個函數,Python會完成其他所有事情.借助這個包,可以輕松完成從單進程到并發執行的轉換.multiprocessing支持子進程.通信和共享數據.執行不同形式的同步,提供了Process.Queue.Pipe.Lock等組件. 引例: 如之前創建多進程的例子 # -*- coding:utf-

前一篇博客說了怎樣通過命名管道實現進程間通信,但是要在windows是使用命名管道,需要使用python調研windows api,太麻煩,于是想到是不是可以通過共享內存的方式來實現.查了一下,Python中可以使用mmap模塊來實現這一功能. Python中的mmap模塊是通過映射同一個普通文件實現共享內存的.文件被映射到進程地址空間后,進程可以像訪問內存一樣對文件進行訪問. 不過,mmap在linux和windows上的API有些許的不一樣,具體細節可以查看mmap的文檔. 下面看一個例子:

Process之間有時需要通信,操作系統提供了很多機制來實現進程間的通信. 1. Queue的使用 可以使用multiprocessing模塊的Queue實現多進程之間的數據傳遞,Queue本身是一個消息列隊程序,首先用一個小實例來演示一下Queue的工作原理: import multiprocessing q = multiprocessing.Queue(3) # 初始化的Queue對象,最多能put三條消息 q.put("消息1") q.put("消息2")

任務調度應用場景 所謂的任務調度是指安排任務的執行計劃,即何時執行,怎么執行等.在現實項目中經常出現它們的身影:特別是數據類項目,比如實時統計每5分鐘網站的訪問量,就需要每5分鐘定時從日志數據分析訪問量. 總結下任務調度應用場景: 離線作業調度:按時間粒度執行某項任務 共享緩存更新:定時刷新緩存,如redis緩存:不同進程間的共享數據 任務調度工具 linux的crontab, 支持按照分鐘/小時/天/月/周粒度,執行任務 java的Quartz windows的任務計劃 本文介紹的是pytho

1 logging模塊簡介 logging模塊是Python內置的標準模塊,主要用于輸出運行日志,可以設置輸出日志的等級.日志保存路徑.日志文件回滾等:相比print,具備如下優點: 可以通過設置不同的日志等級,在release版本中只輸出重要信息,而不必顯示大量的調試信息: print將所有信息都輸出到標準輸出中,嚴重影響開發者從標準輸出中查看其它數據:logging則可以由開發者決定將信息輸出到什么地方,以及怎么輸出: Logger從來不直接實例化,經常通過logging模塊級方法(Modu

一.作用域 在python中,作用域分為兩種:全局作用域和局部作用域. 全局作用域是定義在文件級別的變量,函數名.而局部作用域,則是定義函數內部. 關于作用域,我們要理解兩點: a.在全局不能訪問到局部定義的變量 b.在局部能夠訪問到全局定義的變量,但是不能修改全局定義的變量(當然有方法可以修改) 下面我們來看看下面實例: x = 1 def funx(): x = 10 print(x) # 打印出10 funx() print(x) # 打印出1 如果局部沒有定義變量x,那么函數內部會從內往

python 垃圾收集機制的實例詳解 pythonn垃圾收集方面的內容如果要細講還是挺多的,這里只是做一個大概的概括 Python最主要和絕大多數時候用的都是引用計數,每一個PyObject定義如下: #define PyObject_HEAD \ Py_ssize_t ob_refcnt; \ struct _typeobject *ob_type; typedef struct _object { PyObject_HEAD } PyObject; 每個pyobject都有一個refcnt

一.默認參數 python為了簡化函數的調用,提供了默認參數機制: def pow(x, n = 2): r = 1 while n > 0: r *= x n -= 1 return r 這樣在調用pow函數時,就可以省略最后一個參數不寫: print(pow(5)) # output: 25 在定義有默認參數的函數時,需要注意以下: 必選參數必須在前面,默認參數在后: 設置何種參數為默認參數?一般來說,將參數值變化小的設置為默認參數. python標準庫實踐 python內建函數: prin

Java 存儲模型和共享對象詳解 很多程序員對一個共享變量初始化要注意可見性和安全發布(安全地構建一個對象,并其他線程能正確訪問)等問題不是很理解,認為Java是一個屏蔽內存細節的平臺,連對象回收都不需要關心,因此談到可見性和安全發布大多不知所云.其實關鍵在于對Java存儲模型,可見性和安全發布的問題是起源于Java的存儲結構. Java存儲模型原理 有很多書和文章都講解過Java存儲模型,其中一個圖很清晰地說明了其存儲結構: 由上圖可知, jvm系統中存在一個主內存(Main Memory或J

首先我要吐槽一下,看程序的過程中遇見了yield這個關鍵字,然后百度的時候,發現沒有一個能簡單的讓我懂的,講起來真TM的都是頭頭是道,什么參數,什么傳遞的,還口口聲聲說自己的教程是最簡單的,最淺顯易懂的,我就想問沒有有考慮過讀者的感受. 接下來是正題: 首先,如果你還沒有對yield有個初步分認識,那么你先把yield看做"return",這個是直觀的,它首先是個return,普通的return是什么意思,就是在程序中返回某個值,返回之后程序就不再往下運行了.看做return之后再把它

背景介紹 Expect 程序主要用于人機對話的模擬,就是那種系統提問,人來回答 yes/no ,或者賬號登錄輸入用戶名和密碼等等的情況.因為這種情況特別多而且繁瑣,所以很多語言都有各種自己的實現.最初的第一個 Expect 是由 TCL 語言實現的,所以后來的 Expect 都大致參考了最初的用法和流程,整體來說大致的流程包括: 運行程序 程序要求人的判斷和輸入 Expect 通過關鍵字匹配 根據關鍵字向程序發送符合的字符串 TCL 語言實現的 Expect 功能非常強大,我曾經用它實現了防火墻

總結

以上是生活随笔為你收集整理的python多进程间通信_python多进程间通信代码实例的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。