Python:在从属模式下将命令发送到mplayer

Python:在从属模式下将命令发送到mplayer,第1张

Python:在从属模式下将命令发送到mplayer

.communicate()
每个子流程只能使用一次。因此,在
while
循环中使用它不起作用。

相反,您应该

p.stdout
直接解析的输出。如果有答案,则每个答案似乎只有一行。

为了防止阻塞,您有3种选择:

  1. 使用线程。您有一个单独的线程,该线程从

    p.stdout
    主线程读取数据并将其数据发送到主线程。如果没有可用数据,它将阻止。

  2. 设置

    p.stdout
    为非阻塞模式。本质上,您必须执行以下 *** 作:

    import fcntl, os

    fcntl.fcntl(p.stdout.fileno(), fcntl.F_SETFL,
    fcntl.fcntl(p.stdout.fileno(), fcntl.F_GETFL) | os.O_NONBLOCK)

如果在没有可用数据的情况下进行读取,则会出现异常(

IOError: [Errno 11] Resource temporarilyunavailable
)。

  1. 使用
    select.select()
    p.stdout.readline()
    仅当
    select.select([p.stdout], [], [], <timeout>)[0]
    是非空列表时才执行。在那种情况下,保证给定的文件对象有可用的数据并且在读取时不会阻塞。

为了将“垃圾输出”与“有用”输出分开,您可以这样做:

def perform_command(p, cmd, expect):    import select    p.stdin.write(cmd + 'n') # there's no need for a n at the beginning    while select.select([p.stdout], [], [], 0.05)[0]: # give mplayer time to answer...        output = p.stdout.readline()        print("output: {}".format(output.rstrip()))        split_output = output.split(expect + '=', 1)        if len(split_output) == 2 and split_output[0] == '': # we have found it value = split_output[1] return value.rstrip()

然后做

print perform_command(p, 'get_meta_artist', 'ANS_meta_ARTIST')print perform_command(p, 'get_time_pos', 'ANS_TIME_POSITION')


欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/5587675.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-12-14
下一篇 2022-12-15

发表评论

登录后才能评论

评论列表(0条)

保存