Question

于是我写了一个小的python脚本, 让我可以指定一些文件夹, 包含视频文件, 和一些输出目录, 以及所有视频文件的程序循环, 然后用手刹来转换它们, 例如 :

proc = subprocess.Popen( HandBrakeCLI -i ... -o ... )
proc.wait()

所以它可以逐个处理目录中的每个文件。我有一个四重核心机器, 并且想要通过平行进行视频转换来加快速度, 但我不完全理解如何接近它。

我需要像 os.fork () 那样的东西吗? 更像是多处理模块吗? 我来自单一的刺绣地, 对我来说比较新鲜。

谢谢你的帮助!

Answer 1

类似这般的东西应该能做这个把戏:

import multiprocessing
...
def wrapper(currentfile):
    #create your commandline -- for the sake of simplicity, I assume that
    #the only thing that changes is the filename you are passing to
    #HandBrakeCLI (and that the filename is the last argument to pass)
    cmd= HandBrakeCLI -i ... -o ...  +currentfile 
    proc = subprocess.Popen(cmd)
    proc.wait()
    return  foo 

files=os.listdir(path)  #Any way that you build up your list of files is fine
output = multiprocessing.Pool(4).map(wrapper,files) #output is [ foo ,  foo , ...,  foo ]

当然, 这使用类似 < code> map 的函数来表达许多python 人不喜欢的副作用... 但我觉得它足够直观 -- 特别是如果你留下一个评论的话。我还让函数返回 Foo 来证明您可以很容易地从函数中获取返回值。

Answer 2

我建议使用“https://github.com/kennethreitz/envoy” rel=“nofollow”>envoy 图书馆。在引擎盖下,它利用线线库生成新的 cmd 线程序,所以如果你使用 连接 函数, 像这样 :

import envoy
proc = envoy.connect( HandBrakeCLI -i ... -o ... )
while proc.status_code = None:
    sleep(5)

您可以一次产多少胎, 并等待一个出口再产另一个出口。请注意, 如果您有问题, 我有一个 < a href=" https:// github. com/ srathbun/ envoy" rel=" nofollow" > fork , 您可能想要检查我的修正。

我遇到了一个引号问题, 涉及Shlex图书馆如何处理报价以及你Cmd的线条程序所期望的。自从我把它用在窗户上, 在一个po6/ non-posix 模式的问题中。

友情链接