码迷,mamicode.com
首页 > 编程语言 > 详细

python subprocess阻塞

时间:2016-08-28 13:52:57      阅读:445      评论:0      收藏:0      [点我收藏+]

标签:

import select
import os
import subprocess
import time
import fcntl

args = [‘python‘,‘./fetch_file2.py‘,ip,path]
proc = subprocess.Popen(args, stdout=subprocess.PIPE,stderr=subprocess.PIPE,close_fds=True)

def non_block_read(output):  # 避免阻塞
    fd = output.fileno()
    fl = fcntl.fcntl(fd, fcntl.F_GETFL)
    fcntl.fcntl(fd, fcntl.F_SETFL, fl | os.O_NONBLOCK)
    try:
        return output.read()
    except:
        return ""

while proc.poll() is None: #fetch中rsync结束。但是fetch没有结束(怀疑输出过大)  导致这里一直是None
    pass

                                                
print proc.poll()  # 杀死fetch进程  返回-9
print proc.stderr.read() #阻塞
#方法1: #non_block_read(proc.stderr) #防止阻塞
#方法2: select_rfds = [ proc.stdout, proc.stderr] (rfds, wfds, efds) = select.select(select_rfds, [],[]) if proc.stderr in rfds: #不存在。若select_rfds=[stderr],则阻塞在select上 len = proc.stderr.read(10) if len == 0: print "empty" else: print "proc.stderr" if proc.stdout in rfds: print "proc.stdout"

  

python subprocess阻塞

标签:

原文地址:http://www.cnblogs.com/nerrissa/p/5814795.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!