栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 面试经验 > 面试问答

Python C程序子进程挂在“ for it in iter”

面试问答 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Python C程序子进程挂在“ for it in iter”

这是一个块缓冲问题。

以下是你对Python回答的案例版本的扩展:从

subprocess.communicate()
问题中读取流输入。

直接在C程序中修复stdout缓冲区

stdio通常,如果基于程序的程序在终端中以交互方式运行,则将对这些程序进行行缓冲,并在将其stdout重定向到管道时对这些程序块进行缓冲。在后一种情况下,直到缓冲区溢出或刷新,你才会看到新行。

为了避免fflush()在每次调用之后printf()调用,你可以通过在开始时在C程序中调用来强制行缓冲输出:

setvbuf(stdout, (char *) NULL, _IOLBF, 0); 

在这种情况下,只要打印了换行符,缓冲区就会被刷新。

或在不修改C程序源代码的情况下进行修复

有一个stdbuf实用程序,可让你更改缓冲类型而无需修改源代码,例如:

from subprocess import Popen, PIPEprocess = Popen(["stdbuf", "-oL", "./main"], stdout=PIPE, bufsize=1)for line in iter(process.stdout.readline, b''):    print line,process.communicate() # close process' stream, wait for it to exit

还有其他实用程序,请参阅关闭管道中的缓冲。

或使用伪TTY

要欺骗子进程以使其认为是交互式运行,可以使用pexpect模块或其类似物,有关使用pexpect和pty模块的代码示例,请参见Python子进程readlines()hangs。这是此处pty提供的示例的一种变体(它应在Linux上运行):

#!/usr/bin/env pythonimport osimport ptyimport sysfrom select import selectfrom subprocess import Popen, STDOUTmaster_fd, slave_fd = pty.openpty()  # provide tty to enable line bufferingprocess = Popen("./main", stdin=slave_fd, stdout=slave_fd, stderr=STDOUT,     bufsize=0, close_fds=True)timeout = .1 # ugly but otherwise `select` blocks on process' exit# pre is similar to _copy() from pty.pywith os.fdopen(master_fd, 'r+b', 0) as master:    input_fds = [master, sys.stdin]    while True:        fds = select(input_fds, [], [], timeout)[0]        if master in fds: # subprocess' output is ready data = os.read(master_fd, 512) # <-- doesn't block, may return less if not data: # EOF     input_fds.remove(master) else:     os.write(sys.stdout.fileno(), data) # copy to our stdout        if sys.stdin in fds: # got user input data = os.read(sys.stdin.fileno(), 512) if not data:     input_fds.remove(sys.stdin) else:     master.write(data) # copy it to subprocess' stdin        if not fds: # timeout in select() if process.poll() is not None: # subprocess ended     # and no output is buffered <-- timeout + dead subprocess     assert not select([master], [], [], 0)[0] # race is possible     os.close(slave_fd) # subproces don't need it anymore     breakrc = process.wait()print("subprocess exited with status %d" % rc)

pty通过使用pexpect

pexpect将pty处理包装到更高级别的接口中:

#!/usr/bin/env pythonimport pexpectchild = pexpect.spawn("/.main")for line in child:    print line,child.close()


转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/368443.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号