锐客网

  1. 首页 > 睿知 > it技术 > >

pipe函数python pipe函数使用

文件IT技术

python 多进程 基于官方文档：
【pipe函数python pipe函数使用】日乐购，刚才看到的一个博客，写的都不太对，还是基于官方的比较稳妥
我就是喜欢抄官方的，哈哈
通常我们使用Process实例化一个进程 ， 并调用 他的 start() 方法启动它 。
这种方法和 Thread 是一样的 。
上图中，我写了p.join() 所以主进程是 等待 子进程执行完后 ， 才执行print("运行结束")
否则就是反过来了（这个不一定，看你的语句了，顺序其实是随机的）例如：
主进加个 sleep
所以不加join() ,其实子进程和主进程是各干各的 ， 谁也不等谁 。都执行完后 ， 文件运行就结束了
上面我们用了 os.getpid()和 os.getppid() 获取 当前进程，和父进程的id
下面就讲一下，这两个函数的用法：
os.getpid()
返回当前进程的id
os.getppid()
返回父进程的id 。父进程退出后，unix 返回初始化进程（1）中的一个
windows返回相同的id (可能被其他进程使用了)
这也就解释了，为啥我上面 的程序运行多次， 第一次打印的parentid都是 14212 了 。
而子进程的父级 process id 是调用他的那个进程的 id ： 1940
视频笔记：
多进程：使用大致方法：
参考： 进程通信（pipe和queue）
pool.map（函数可以有return也可以共享内存或queue） 结果直接是个列表
poll.apply_async()（同map,只不过是一个进程 ， 返回结果用 xx.get() 获得）
报错：
参考 ：
把 pool = Pool()放到 ifname== " main ": 下面初始化搞定 。
结果：
这个肯定有解释的
测试多进程计算效果：
进程池运行：
结果：
普通计算：
我们同样传入 1 2 10 三个参数测试：
其实对比下来开始快了一半的；
我们把循环里的数字去掉一个 0；
单进程：
多进程：
两次测试单进程/进程池分别为 0.669 和 0.772几乎成正比的 。
问题 二：
视图：
post 视图里面
Music 类：
直接报错：
写在 类里面也 在函数里用 self.pool调用也不行，也是相同的错误 。
最后 把 pool = Pool 直接写在 search 函数里面，奇迹出现了：
前台也能显示搜索的音乐结果了
总结一点，进程这个东西，最好 写在 直接运行的函数里面，而不是 一个函数跳来跳去 。因为最后可能 是在子进程的子进程运行的，这是不许的，会报错 。
还有一点，多进程运行的函数对象，不能是 lambda 函数 。也许lambda 虚拟，在内存？？
使用 pool.map 子进程 函数报错，导致整个 pool 挂了:
参考：
主要你要，对函数内部捕获错误，而不能让异常抛出就可以了 。
关于map 传多个函数参数
我一开始，就是正常思维，多个参数，搞个元祖，让参数一一对应不就行了：
报错：
参考：
普通的 process 当让可以穿多个参数，map 却不知道咋传的 。
apply_async和map 一样，不知道咋传的 。
最简单的方法：
使用 starmap 而不是 map
结果：
子进程结束
1.8399453163146973
成功拿到结果了
关于map 和 starmap 不同的地方看源码：
关于apply_async() ,我没找到多参数的方法，大不了用 一个迭代的starmap 实现 。哈哈
关于 上面源码里面有 itertools.starmap
itertools 用法参考：
有个问题 ， 多进程最好不要使用全部的 cpu , 因为这样可能影响其他任务 ， 所以 在进程池 添加 process参数 指定，cpu 个数：
上面就是预留了 一个cpu 干其他事的
后面直接使用 Queue 遇到这个问题：
解决：
Manager().Queue()代替 Queue()
因为 queue.get() 是堵塞型的 ， 所以可以提前判断是不是 空的，以免堵塞进程 。比如下面这样：
使用 queue.empty()空为True
python 中os.system和commands.getoutput的区别1. 使用os.system("cmd")
这是最简单的一种方法，特点是执行的时候程序会打出cmd在linux上执行的信息 。使用前需要import os 。
[python]
os.system("ls")
2. 使用Popen模块产生新的process
现在大部分人都喜欢使用Popen 。Popen方法不会打印出cmd在linux上执
行的信息 。的确，Popen非常强大，支持多种参数和模式 。使用前需要from subprocess import Popen,
PIPE 。但是Popen函数有一个缺陷，就是它是一个阻塞的方法 。如果运行cmd时产生的内容非常多，函数非常容易阻塞住 。解决办法是不使用
wait()方法，但是也不能获得执行的返回值pipe函数python了 。
Popen原型是pipe函数python：
[python]
subprocess.Popen(args, bufsize=0, executable=None, stdin=None, stdout=None, stderr=None, preexec_fn=None, close_fds=False, shell=False, cwd=None, env=None, universal_newlines=False, startupinfo=None, creationflags=0)
参数bufsize：指定缓冲 。我到现在还不清楚这个参数的具体含义，望各个大牛指点 。
参数executable用于指定可执行程序 。一般情况下我们通过args参数来设置所要运行的程序 。如果将参数shell设为 True，executable将指定程序使用的shell 。在windows平台下，默认的shell由COMSPEC环境变量来指定 。
参数stdin, stdout, stderr分别表示程序的标准输入、输出、错误句柄 。他们可以是PIPE，文件描述符或文件对象，也可以设置为None ， 表示从父进程继承 。
参数preexec_fn只在Unix平台下有效，用于指定一个可执行对象（callable object），它将在子进程运行之前被调用 。
参数Close_sfs：在windows平台
下，如果close_fds被设置为True，则新创建的子进程将不会继承父进程的输入、输出、错误管
道 。我们不能将close_fds设置为True同时重定向子进程的标准输入、输出与错误(stdin, stdout, stderr) 。
如果参数shell设为true ， 程序将通过shell来执行 。
参数cwd用于设置子进程的当前目录 。
参数env是字典类型，用于指定子进程的环境变量 。如果env = None，子进程的环境变量将从父进程中继承 。
参数Universal_newlines:不同操作系统下，文本的换行符是不一样的 。如：windows下用’/r/n’表示换，而Linux下用 ‘/n’ 。如果将此参数设置为True ， Python统一把这些换行符当作’/n’来处理 。
参数startupinfo与createionflags只在windows下用效 ， 它们将被传递给底层的CreateProcess()函数，用 于设置子进程的一些属性 ， 如：主窗口的外观，进程的优先级等等 。
subprocess.PIPE
在创建Popen对象时，subprocess.PIPE可以初始化stdin, stdout或stderr参数，表示与子进程通信的标准流 。
subprocess.STDOUT
创建Popen对象时，用于初始化stderr参数，表示将错误通过标准输出流输出 。
Popen的方法：
Popen.poll()
用于检查子进程是否已经结束 。设置并返回returncode属性 。
Popen.wait()
等待子进程结束 。设置并返回returncode属性 。
Popen.communicate(input=None)
与子进程进行交互 。向stdin发送数据，或从stdout和stderr中读取数据 。可选参数input指定发送到子进程的参数 。
Communicate()返回一个元组：(stdoutdata,
stderrdata) 。注意：如果希望通过进程的stdin向其发送数据，在创建Popen对象的时候 ， 参数stdin必须被设置为PIPE 。同样，如
果希望从stdout和stderr获取数据，必须将stdout和stderr设置为PIPE 。
Popen.send_signal(signal)
向子进程发送信号 。
Popen.terminate()
停止(stop)子进程 。在windows平台下 ， 该方法将调用Windows API TerminateProcess（）来结束子进程 。
Popen.kill()
杀死子进程 。
Popen.stdin
如果在创建Popen对象是，参数stdin被设置为PIPE，Popen.stdin将返回一个文件对象用于策子进程发送指令 。否则返回None 。
Popen.stdout
如果在创建Popen对象是 ， 参数stdout被设置为PIPE，Popen.stdout将返回一个文件对象用于策子进程发送指令 。否则返回 None 。
Popen.stderr
如果在创建Popen对象是，参数stdout被设置为PIPE ， Popen.stdout将返回一个文件对象用于策子进程发送指令 。否则返回 None 。
Popen.pid
获取子进程的进程ID 。
Popen.returncode
获取进程的返回值 。如果进程还没有结束，返回None 。
例如：
[python]
p = Popen("cp -rf a/* b/", shell=True, stdout=PIPE, stderr=PIPE)
p.wait()
if p.returncode != 0:
print "Error."
return -1
3. 使用commands.getstatusoutput方法
这个方法也不会打印出cmd在linux上执行的信息 。这个方法唯一的优点是，它不是一个阻塞的方法 。即没有Popen函数阻塞的问题 。使用前需要import commands 。
例如：
[python]
status, output = commands.getstatusoutput("ls")
还有只获得output和status的方法：
[python]
commands.getoutput("ls")
commands.getstatus("ls")
python 基础教程 运算
a = 21
b = 10
c = 0
c = ab
print "1 - c 的值为：", c
c = a - b
print "2 - c 的值为：", c
c = a * b
print "3 - c 的值为：", c
c = a / b
print "4 - c 的值为：", c
c = a % b
print "5 - c 的值为：", c
a = 2
b = 3
c = a**b
print "6 - c 的值为：", c
a = 10
b = 5
c = a//b
print "7 - c 的值为：", c
python比较
a = 21
b = 10
c = 0
if ( a == b ):
print "1 - a 等于 b"
else:
print "1 - a 不等于 b"
if ( a != b ):
print "2 - a 不等于 b"
else:
print "2 - a 等于 b"
if ( ab ):
print "3 - a 不等于 b"
else:
print "3 - a 等于 b"
if ( ab ):
print "4 - a 小于 b"
else:
print "4 - a 大于等于 b"
if ( ab ):
print "5 - a 大于 b"
else:
print "5 - a 小于等于 b"
a = 5
b = 20
if ( a = b ):
print "6 - a 小于等于 b"
else:
print "6 - a 大于b"
if ( b = a ):
print "7 - b 大于等于 a"
else:
print "7 - b 小于 a"
赋值
a = 21
b = 10
c = 0
c = ab
print "1 - c 的值为：", c
c= a
print "2 - c 的值为：", c
c *= a
print "3 - c 的值为：", c
c /= a
print "4 - c 的值为：", c
c = 2
c %= a
print "5 - c 的值为：", c
c **= a
print "6 - c 的值为：", c
c //= a
print "7 - c 的值为：", c
逻辑运算符：
a = 10
b = 20
if ( a and b ):
print "1 - 变量 a 和 b 都为 true"
else:
print "1 - 变量 a 和 b 有一个不为 true"
if ( a or b ):
print "2 - 变量 a 和 b 都为 true，或其中一个变量为 true"
else:
print "2 - 变量 a 和 b 都不为 true"
a = 0
if ( a and b ):
print "3 - 变量 a 和 b 都为 true"
else:
print "3 - 变量 a 和 b 有一个不为 true"
if ( a or b ):
print "4 - 变量 a 和 b 都为 true，或其中一个变量为 true"
else:
print "4 - 变量 a 和 b 都不为 true"
if not( a and b ):
print "5 - 变量 a 和 b 都为 false，或其中一个变量为 false"
else:
print "5 - 变量 a 和 b 都为 true"
in,not in
a = 10
b = 20
list = [1, 2, 3, 4, 5 ];
if ( a in list ):
print "1 - 变量 a 在给定的列表中 list 中"
else:
print "1 - 变量 a 不在给定的列表中 list 中"
if ( b not in list ):
print "2 - 变量 b 不在给定的列表中 list 中"
else:
print "2 - 变量 b 在给定的列表中 list 中"
a = 2
if ( a in list ):
print "3 - 变量 a 在给定的列表中 list 中"
else:
print "3 - 变量 a 不在给定的列表中 list 中"
条件
flag = False
name = 'luren'
if name == 'python':# 判断变量否为'python'
flag = True# 条件成立时设置标志为真
print 'welcome boss'# 并输出欢迎信息
else:
print name
num = 5
if num == 3:# 判断num的值
print 'boss'
elif num == 2:
print 'user'
elif num == 1:
print 'worker'
elif num0:# 值小于零时输出
print 'error'
else:
print 'roadman'# 条件均不成立时输出
循环语句：
count = 0
while (count9):
print 'The count is:', count
count = count1
print "Good bye!"
i = 1
while i10:
i= 1
if i :# 非双数时跳过输出
continue
print i# 输出双数2、4、6、8、10
i = 1
while 1:# 循环条件为1必定成立
print i# 输出1~10
i= 1
if i10:# 当i大于10时跳出循环
break
for letter in 'Python':# 第一个实例
print '当前字母 :', letter
fruits = ['banana', 'apple','mango']
for fruit in fruits:# 第二个实例
print '当前水果 :', fruit
print "Good bye!"
获取用户输入:raw_input
var = 1
while var == 1 :# 该条件永远为true，循环将无限执行下去
num = raw_input("Enter a number:")
print "You entered: ", num
print "Good bye!"
range,len
fruits = ['banana', 'apple','mango']
for index in range(len(fruits)):
print '当前水果 :', fruits[index]
print "Good bye!"
python数学函数：
abs,cell,cmp,exp,fabs,floor,log,log10,max,min,mod,pow,round,sqrt
randrange
访问字符串的值
var1 = 'Hello World!'
var2 = "Python Runoob"
print "var1[0]: ", var1[0]
print "var2[1:5]: ", var2[1:5]
转义字符
格式化输出
print "My name is %s and weight is %d kg!" % ('Zara', 21)
字符串函数：
添加元素
list = []## 空列表
list.append('Google')## 使用 append() 添加元素
list.append('Runoob')
print list
删除元素
list1 = ['physics', 'chemistry', 1997, 2000]
print list1
del list1[2]
print "After deleting value at index 2 : "
print list1
列表操作
列表方法
删除字典
dict = {'Name': 'Zara', 'Age': 7, 'Class': 'First'};
del dict['Name']; # 删除键是'Name'的条目
dict.clear();# 清空词典所有条目
del dict ;# 删除词典
print "dict['Age']: ", dict['Age'];
print "dict['School']: ", dict['School'];
字典的函数：
当前时间戳：
import time
time.time()
格式化日期输出
import time
print time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
print time.strftime("%a %b %d %H:%M:%S %Y", time.localtime())
a = "Sat Mar 28 22:24:24 2016"
print time.mktime(time.strptime(a,"%a %b %d %H:%M:%S %Y"))
获取某个月日历：calendar
import calendar
cal = calendar.month(2016, 1)
print "以下输出2016年1月份的日历:"
print cal
当前日期和时间
import datetime
i = datetime.datetime.now()
print ("当前的日期和时间是 %s" % i)
print ("ISO格式的日期和时间是 %s" % i.isoformat() )
print ("当前的年份是 %s" %i.year)
print ("当前的月份是 %s" %i.month)
print ("当前的日期是%s" %i.day)
print ("dd/mm/yyyy 格式是%s/%s/%s" % (i.day, i.month, i.year) )
print ("当前小时是 %s" %i.hour)
print ("当前分钟是 %s" %i.minute)
print ("当前秒是%s" %i.second)
不定长参数：*
lambda：匿名函数
def....
python模块搜索路径
获取用户输入
str = raw_input("请输入：")
print "你输入的内容是: ", str
input可以接收表达式
open参数
write要自己添加换行符
读取10个字符
重命名：os.rename
os.remove
os.mkdiros.chdir
os.getcwd
os.rmdir
open参数
file的方法
异常：
try:
fh = open("testfile", "w")
fh.write("这是一个测试文件，用于测试异常!!")
except IOError:
print "Error: 没有找到文件或读取文件失败"
else:
print "内容写入文件成功"
fh.close()
try:
fh = open("testfile", "w")
fh.write("这是一个测试文件，用于测试异常!!")
finally:
print "Error: 没有找到文件或读取文件失败"
用户自定义异常：
os模块提供了非常丰富的方法用来处理文件和目录 。常用的方法如下表所示：
| 序号 | 方法及描述 |
| 1 |
os.access(path, mode)
检验权限模式 |
| 2 |
os.chdir(path)
改变当前工作目录 |
| 3 |
os.chflags(path, flags)
设置路径的标记为数字标记 。|
| 4 |
os.chmod(path, mode)
更改权限 |
| 5 |
os.chown(path, uid, gid)
更改文件所有者 |
| 6 |
os.chroot(path)
改变当前进程的根目录 |
| 7 |
os.close(fd)
关闭文件描述符 fd |
| 8 |
os.closerange(fd_low, fd_high)
关闭所有文件描述符 ， 从 fd_low (包含) 到 fd_high (不包含), 错误会忽略 |
| 9 |
os.dup(fd)
复制文件描述符 fd |
| 10 |
os.dup2(fd, fd2)
将一个文件描述符 fd 复制到另一个 fd2 |
| 11 |
os.fchdir(fd)
通过文件描述符改变当前工作目录 |
| 12 |
os.fchmod(fd, mode)
改变一个文件的访问权限，该文件由参数fd指定，参数mode是Unix下的文件访问权限 。|
| 13 |
os.fchown(fd, uid, gid)
修改一个文件的所有权，这个函数修改一个文件的用户ID和用户组ID，该文件由文件描述符fd指定 。|
| 14 |
os.fdatasync(fd)
强制将文件写入磁盘，该文件由文件描述符fd指定，但是不强制更新文件的状态信息 。|
| 15 |
os.fdopen(fd[, mode[, bufsize]])
通过文件描述符 fd 创建一个文件对象 ， 并返回这个文件对象 |
| 16 |
os.fpathconf(fd, name)
返回一个打开的文件的系统配置信息 。name为检索的系统配置的值，它也许是一个定义系统值的字符串 ， 这些名字在很多标准中指定（POSIX.1, Unix 95, Unix 98, 和其它） 。|
| 17 |
os.fstat(fd)
返回文件描述符fd的状态，像stat() 。|
| 18 |
os.fstatvfs(fd)
返回包含文件描述符fd的文件的文件系统的信息，像 statvfs() |
| 19 |
os.fsync(fd)
强制将文件描述符为fd的文件写入硬盘 。|
| 20 |
os.ftruncate(fd, length)
裁剪文件描述符fd对应的文件, 所以它最大不能超过文件大小 。|
| 21 |
os.getcwd()
返回当前工作目录 |
| 22 |
os.getcwdu()
返回一个当前工作目录的Unicode对象 |
| 23 |
os.isatty(fd)
如果文件描述符fd是打开的，同时与tty(-like)设备相连，则返回true, 否则False 。|
| 24 |
os.lchflags(path, flags)
设置路径的标记为数字标记，类似 chflags()，但是没有软链接 |
| 25 |
os.lchmod(path, mode)
修改连接文件权限 |
| 26 |
os.lchown(path, uid, gid)
更改文件所有者 ， 类似 chown，但是不追踪链接 。|
| 27 |
os.link(src, dst)
创建硬链接，名为参数 dst，指向参数 src |
| 28 |
os.listdir(path)
返回path指定的文件夹包含的文件或文件夹的名字的列表 。|
| 29 |
os.lseek(fd, pos, how)
设置文件描述符 fd当前位置为pos, how方式修改: SEEK_SET 或者 0 设置从文件开始的计算的pos; SEEK_CUR或者 1 则从当前位置计算; os.SEEK_END或者2则从文件尾部开始. 在unix ， Windows中有效 |
| 30 |
os.lstat(path)
像stat(),但是没有软链接 |
| 31 |
os.major(device)
从原始的设备号中提取设备major号码 (使用stat中的st_dev或者st_rdev field) 。|
| 32 |
os.makedev(major, minor)
以major和minor设备号组成一个原始设备号 |
| 33 |
os.makedirs(path[, mode])
递归文件夹创建函数 。像mkdir(), 但创建的所有intermediate-level文件夹需要包含子文件夹 。|
| 34 |
os.minor(device)
从原始的设备号中提取设备minor号码 (使用stat中的st_dev或者st_rdev field ) 。|
| 35 |
os.mkdir(path[, mode])
以数字mode的mode创建一个名为path的文件夹.默认的 mode 是 0777 (八进制) 。|
| 36 |
os.mkfifo(path[, mode])
创建命名管道 ， mode 为数字，默认为 0666 (八进制) |
| 37 |
os.mknod(filename[, mode=0600, device])
创建一个名为filename文件系统节点（文件，设备特别文件或者命名pipe） 。
|
| 38 |
os.open(file, flags[, mode])
打开一个文件，并且设置需要的打开选项，mode参数是可选的 |
| 39 |
os.openpty()
打开一个新的伪终端对 。返回 pty 和 tty的文件描述符 。|
| 40 |
os.pathconf(path, name)
返回相关文件的系统配置信息 。|
| 41 |
os.pipe()
创建一个管道. 返回一对文件描述符(r, w) 分别为读和写 |
| 42 |
os.popen(command[, mode[, bufsize]])
从一个 command 打开一个管道 |
| 43 |
os.read(fd, n)
从文件描述符 fd 中读取最多 n 个字节，返回包含读取字节的字符串，文件描述符 fd对应文件已达到结尾, 返回一个空字符串 。|
| 44 |
os.readlink(path)
返回软链接所指向的文件 |
| 45 |
os.remove(path)
删除路径为path的文件 。如果path 是一个文件夹，将抛出OSError; 查看下面的rmdir()删除一个 directory 。|
| 46 |
os.removedirs(path)
递归删除目录 。|
| 47 |
os.rename(src, dst)
重命名文件或目录 ， 从 src 到 dst |
| 48 |
os.renames(old, new)
递归地对目录进行更名，也可以对文件进行更名 。|
| 49 |
os.rmdir(path)
删除path指定的空目录 ， 如果目录非空，则抛出一个OSError异常 。|
| 50 |
os.stat(path)
获取path指定的路径的信息，功能等同于C API中的stat()系统调用 。|
| 51 |
os.stat_float_times([newvalue])
决定stat_result是否以float对象显示时间戳
|
| 52 |
os.statvfs(path)
获取指定路径的文件系统统计信息 |
| 53 |
os.symlink(src, dst)
创建一个软链接 |
| 54 |
os.tcgetpgrp(fd)
返回与终端fd（一个由os.open()返回的打开的文件描述符）关联的进程组 |
| 55 |
os.tcsetpgrp(fd, pg)
设置与终端fd（一个由os.open()返回的打开的文件描述符）关联的进程组为pg 。|
| 56 |
os.tempnam([dir[, prefix]])
返回唯一的路径名用于创建临时文件 。|
| 57 |
os.tmpfile()
返回一个打开的模式为(w b)的文件对象 .这文件对象没有文件夹入口 ， 没有文件描述符，将会自动删除 。|
| 58 |
os.tmpnam()
为创建一个临时文件返回一个唯一的路径 |
| 59 |
os.ttyname(fd)
返回一个字符串，它表示与文件描述符fd 关联的终端设备 。如果fd 没有与终端设备关联，则引发一个异常 。|
| 60 |
os.unlink(path)
删除文件路径 |
| 61 |
os.utime(path, times)
返回指定的path文件的访问和修改的时间 。|
| 62 |
os.walk(top[, topdown=True[, onerror=None[, followlinks=False]]])
输出在文件夹中的文件名通过在树中游走 ， 向上或者向下 。|
| 63 |
os.write(fd, str)
写入字符串到文件描述符 fd中. 返回实际写入的字符串长度 |
python stdin 为pipe什么意思Linux中进程的通信方式有信号，管道，共享内存，消息队列socket等 。其中管道是*nix系统进程间通信的最古老形式，所有*nix都提供这种通信方式 。管道是一种半双工的通信机制，也就是说，它只能一端用来读，另外一端用来写；另外，管道只能用来在具有公共祖先的两个进程之间通信 。管道通信遵循先进先出的原理，并且数据只能被读取一次，当此段数据被读取后，马上会从数据中消失，这一点很重要 。
Linux上，创建管道使用pipe函数，当它执行后，会产生两个文件描述符，分别为读端和写端 。单个进程中的管道几乎没有任何作用，通常会先调用pipe，然后调用fork，从而创建从父进程到子进程的IPC通道 。
Linux中，我们经常会使用到管道，例如用cat命令查看一个大文件时，一页不能全部显示 ， 我们可以通过cat xxx | more来分页显示，又比如搜索文件里的内容可以用 cat xxx | grep search来进行，这里我们都用到了管道 。接下来我会用python编写一段自动分页显示的程序 ， 而不用手动来使用管道 。
#!/usr/bin/env python
import os,sys
if 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，增加执行权限之后 ， 运行 scat.py 文件名，系统就会自动读取文件的内容并分页 ， 与使用 cat 文件名 | more 的效果是一模一样的 。在上面的代码中，用到了前几篇博客中说的fork，dup2和exec系列函数 。
python编程中 os.mkfifo()和os.mknod()函数具体用法？最好有例子 ， 里面参数具体怎么配置就能创建管道或节mkfifo函数使用
[code]mkfifo（建立实名管道）
相关函数
pipe，popen，open ， umask
表头文件
#include
#include
定义函数
int mkfifo(const char * pathname,mode_t mode);
函数说明
mkfifo() 会依参数pathname建立特殊的FIFO文件，该文件必须不存在，而参数mode为该文件的权限（mode%~umask），因此 umask值也会影响到FIFO文件的权限 。Mkfifo()建立的FIFO文件其他进程都可以用读写一般文件的方式存取 。当使用open()来打开 FIFO文件时，O_NONBLOCK旗标会有影响
1、当使用O_NONBLOCK 旗标时，打开FIFO 文件来读取的操作会立刻返回，但是若还没有其他进程打开FIFO 文件来读取，则写入的操作会返回ENXIO 错误代码 。
2、没有使用O_NONBLOCK 旗标时，打开FIFO 来读取的操作会等到其他进程打开FIFO文件来写入才正常返回 。同样地，打开FIFO文件来写入的操作会等到其他进程打开FIFO 文件来读取后才正常返回 。
返回值
若成功则返回0 ， 否则返回-1，错误原因存于errno中 。
错误代码
EACCESS 参数pathname所指定的目录路径无可执行的权限
EEXIST 参数pathname所指定的文件已存在 。
ENAMETOOLONG 参数pathname的路径名称太长 。
ENOENT 参数pathname包含的目录不存在
ENOSPC 文件系统的剩余空间不足
ENOTDIR 参数pathname路径中的目录存在但却非真正的目录 。
EROFS 参数pathname指定的文件存在于只读文件系统内 。
示例1:
#include
#include
#include
#include
int main(void)
{
char buf[80];
int fd;
unlink( "zieckey_fifo" );
mkfifo( "zieckey_fifo", 0777 );
if ( fork()0 )
{
char s[] = "Hello!\n";
fd = open( "zieckey_fifo", O_WRONLY );
write( fd, s, sizeof(s) );
//close( fd );
}
else
{
fd = open( "zieckey_fifo", O_RDONLY );
read( fd, buf, sizeof(buf) );
printf("The message from the pipe is:%s\n", buf );
//close( fd );
}
return 0;
}
执行
hello!
示例2:
#include
#include
#include
#include
#include
int main( int argc, char **argv )
{
mode_t mode = 0666;
if ( argc !=2 )
{
printf( "Usage:[%s] fifo_filename\n", argv[0] );
return -1;
}
if (mkfifo( argv[1], mode)0 )
{
perror( "mkfifo");
return -1;
}
return 0;
} [/code]
pipe函数python的介绍就聊到这里吧 ， 感谢你花时间阅读本站内容，更多关于pipe函数使用、pipe函数python的信息别忘了在本站进行查找喔 。

    推荐阅读


    上一篇：如何配置腾讯通服务器？ 腾讯通服务器怎么配置

    下一篇：如何找到热门服务器？ 怎么查看热点的服务器