国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > Python > 正文

Python中使用PIPE操作Linux管道

2020-02-23 06:23:38
字體:
來源:轉載
供稿:網友

Linux中進程的通信方式有信號,管道,共享內存,消息隊列socket等。其中管道是*nix系統(tǒng)進程間通信的最古老形式,所有*nix都提供這種通信方式。管道是一種半雙工的通信機制,也就是說,它只能一端用來讀,另外一端用來寫;另外,管道只能用來在具有公共祖先的兩個進程之間通信。管道通信遵循先進先出的原理,并且數(shù)據(jù)只能被讀取一次,當此段數(shù)據(jù)被讀取后,馬上會從數(shù)據(jù)中消失,這一點很重要。

Linux上,創(chuàng)建管道使用pipe函數(shù),當它執(zhí)行后,會產生兩個文件描述符,分別為讀端和寫端。單個進程中的管道幾乎沒有任何作用,通常會先調用pipe,然后調用fork,從而創(chuàng)建從父進程到子進程的IPC通道。

Linux中,我們經常會使用到管道,例如用cat命令查看一個大文件時,一頁不能全部顯示,我們可以通過cat xxx | more來分頁顯示,又比如搜索文件里的內容可以用 cat xxx | grep search來進行,這里我們都用到了管道。接下來我會用python編寫一段自動分頁顯示的程序,而不用手動來使用管道。

#!/usr/bin/env pythonimport os,sysif not sys.argv[1:]:  print "No filename input"  sys.exit(1)try:    fp = open(sys.argv[1],"r")except IOError,msg:  sys.exit(msg)pi=os.pipe()pid=os.fork()if pid:  #parent  os.close(pi[0]) #close read pipe  #write to pipe  line=fp.readline()  while line:    os.write(pi[1],line)    line=fp.readline()  #close write pipe  os.close(pi[1])  #wait for chile  os.waitpid(pid,0)else:  os.close(pi[1]) #close write pipe  #put pipe read to stdin  os.dup2(pi[0],sys.stdin.fileno())  os.close(pi[0])  os.execl("/bin/more","more")

把這段代碼存為scat.py,增加執(zhí)行權限之后,運行 scat.py 文件名,系統(tǒng)就會自動讀取文件的內容并分頁,與使用 cat 文件名 | more 的效果是一模一樣的。在上面的代碼中,用到了前幾篇博客中說的fork,dup2和exec系列函數(shù)。

首先是程序創(chuàng)建了一個管道,系統(tǒng)fork之后,父進程關閉其讀端,子進程關閉其寫端,接下來父進程讀取傳遞過來的文件名,并把內容通過管道的寫入端口寫入管道里,然后關閉寫入端口,并等待子進程的結束。子進程在關閉寫入端口后,把讀取端口重定向到進程的標準輸入,子進程就能自動接收到管道傳遞過來的數(shù)據(jù),最后用execl函數(shù)調用系統(tǒng)的more程序用來處理傳遞過來的數(shù)據(jù),這樣,就輕松實現(xiàn)的分頁的效果。

pipe是半雙工的通信機制,如果進程間要使用全雙工的通信,可以創(chuàng)建兩條管道來達到全雙工的效果。另外,pipe匿名管道只能用來在擁有同一個父進程的進程間通信,*nix提供另外一個fifo(命名管道)可以讓任意的進程之間實現(xiàn)通信,會在接下來的博客中來講。

發(fā)表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發(fā)表
主站蜘蛛池模板: 赞皇县| 乐昌市| 保定市| 临沂市| 玉山县| 康平县| 肃北| 广元市| 电白县| 务川| 永泰县| 扶绥县| 会昌县| 平昌县| 青海省| 资溪县| 襄汾县| 通渭县| 会东县| 玛多县| 上蔡县| 缙云县| 城固县| 公主岭市| 滨海县| 分宜县| 普安县| 高阳县| 洛南县| 资阳市| 界首市| 聊城市| 定边县| 湘潭县| 双流县| 青田县| 固安县| 富阳市| 当涂县| 五常市| 姚安县|