詳解Python進(jìn)程間通信之命名管道
管道是一種簡(jiǎn)單的FIFO通信信道,它是單向通信的。 通常啟動(dòng)進(jìn)程創(chuàng)建一個(gè)管道,然后這個(gè)進(jìn)程創(chuàng)建一個(gè)或者多個(gè)進(jìn)程子進(jìn)程接受管道信息,由于管道是單向通信,所以經(jīng)常需要?jiǎng)?chuàng)建兩個(gè)管道來實(shí)現(xiàn)雙向通信。
命名管道是對(duì)傳統(tǒng)管道的擴(kuò)展,默認(rèn)的管道是匿名管道,只在程序運(yùn)行時(shí)存在;而命名管道是持久化的,當(dāng)不需要時(shí)需要?jiǎng)h除它。
命名管道使用文件系統(tǒng),由mkfifo()方法創(chuàng)建。一旦創(chuàng)建了,兩個(gè)獨(dú)立的進(jìn)程都可以訪問它,一個(gè)讀,另外一個(gè)寫。
命名管道支持阻塞讀和阻塞寫操作: 如果一個(gè)進(jìn)程打開文件讀,它會(huì)阻塞直到另外一個(gè)進(jìn)程寫。 但是我們可以指定O_NONBLOCK選項(xiàng)來啟用非阻塞模式。
命名管道必須以只讀或者只寫的模式打開,它不能以讀+寫的模式打開,因?yàn)樗鼤r(shí)單向通信。如果要實(shí)現(xiàn)雙向通信,必須打開兩個(gè)命名管道。
下面是一個(gè) Python 使用命名管道來實(shí)現(xiàn)進(jìn)程間通信的例子
Server 端
import os, time read_path = "/tmp/pipe.in" write_path = "/tmp/pipe.out" if os.path.exists(read_path): os.remove(read_path) if os.path.exists(write_path): os.remove(write_path) os.mkfifo(write_path) os.mkfifo(read_path) rf = os.open(read_path, os.O_RDONLY) wf = os.open(write_path, os.O_SYNC | os.O_CREAT | os.O_RDWR) while True: s = os.read(rf, 1024) print "received msg: %s" % s if len(s) == 0: time.sleep(1) continue if "exit" in s: break os.write(wf, s) os.close(rf) os.close(wf)
Client 端
import os import time write_path = "/tmp/pipe.in" read_path = "/tmp/pipe.out" wf = os.open(write_path, os.O_SYNC | os.O_CREAT | os.O_RDWR) rf = None for i in range(1, 11): msg = "msg " + str(i) len_send = os.write(wf, msg) print "sent msg: %s" % msg if rf is None: rf = os.open(read_path, os.O_RDONLY) s = os.read(rf, 1024) if len(s) == 0: break print "received msg: %s" % s time.sleep(1) os.write(wf, 'exit') os.close(rf) os.close(wf)
測(cè)試
- 首先運(yùn)行server.py
- 然后運(yùn)行client.py
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
python?AutoViz庫(kù)一行代碼實(shí)現(xiàn)可視化數(shù)據(jù)集
這篇文章主要介紹了python?AutoViz庫(kù)一行代碼實(shí)現(xiàn)可視化數(shù)據(jù)集實(shí)例探索,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2024-01-01Python?OpenCV實(shí)現(xiàn)人物動(dòng)漫化效果
這篇文章主要介紹了利用Python和OpenCV實(shí)現(xiàn)人物的動(dòng)漫化特效,文中的示例代碼講解詳細(xì),對(duì)我們學(xué)習(xí)Python和OpenCV有一定的幫助,需要的可以了解一下2022-01-01python動(dòng)態(tài)規(guī)劃算法實(shí)例詳解
在本篇文章里小編給大家整理了關(guān)于python動(dòng)態(tài)規(guī)劃算法實(shí)例內(nèi)容,有需要的朋友們可以參考學(xué)習(xí)下。2020-11-11關(guān)于Python如何安裝requests庫(kù)
這篇文章主要介紹了關(guān)于Python如何安裝requests庫(kù),requests庫(kù)自稱“HTTP for Humans”,直譯過來的意思是專門為人類設(shè)計(jì)的HTTP庫(kù),能夠被開發(fā)人員安全地使用,需要的朋友可以參考下2023-04-04Python NumPy數(shù)組利器之np.zeros函數(shù)詳解與應(yīng)用實(shí)例
在Python的科學(xué)計(jì)算庫(kù)NumPy中,numpy.zeros()是一個(gè)非常重要的函數(shù),它用于創(chuàng)建一個(gè)指定形狀和數(shù)據(jù)類型的全零數(shù)組,這篇文章主要給大家介紹了關(guān)于Python NumPy數(shù)組利器之np.zeros函數(shù)詳解與應(yīng)用實(shí)例的相關(guān)資料,需要的朋友可以參考下2024-06-06python實(shí)現(xiàn)精準(zhǔn)搜索并提取網(wǎng)頁(yè)核心內(nèi)容
這篇文章主要為大家介紹了python實(shí)現(xiàn)精準(zhǔn)搜索并提取網(wǎng)頁(yè)核心內(nèi)容的實(shí)現(xiàn),有需要的的朋友可以借鑒參考下,希望能有所幫助祝大家多多進(jìn)步2021-11-11