0

我想并行运行 2 个函数，并使用一个函数的返回值（连续存储在列表中）用于另一个函数。

我已经编写了一些功能来实现上述功能（从这个论坛上的一些帖子中获得帮助）。

u=[]

def func_a():
Num1=10000
for i1 in range(callNum1):
    ul = <some_function_returns_a_value>
    u.append(ul)

def func_b():
Num2=10000
time.sleep(30)
for i2 in range(Num2):
    ul1=u.pop(i2)
    print ul1

def RunP(*fns):
    proc = []
    for fn in fns:
        p = Process(target=fn)
        p.start()
        proc.append(p)
    for p in proc:
        p.join()

我将这两个函数都称为如下

RunP(func_a, func_b)

但是当我运行它时，我得到了这个错误：

RunP(func_a, func_b)
Process Process-2:
Traceback (most recent call last):
  File "/usr/lib/python2.4/site-packages/multiprocessing-2.6.2.1-py2.4-linux-i686.egg/multiprocessing/process.py", line 237, in _bootstrap
    self.run()
  File "/usr/lib/python2.4/site-packages/multiprocessing-2.6.2.1-py2.4-linux-i686.egg/multiprocessing/process.py", line 93, in run
    self._target(*self._args, **self._kwargs)
  File "test.py", line 419, in func_b
    ul1=u.pop(i2)
IndexError: pop from empty list

请帮助我完成预期的任务。

4

1 回答 1

4

听起来你想使用Queue.

这是一个与您的代码有些相似的快速'n'dirty示例：

import multiprocessing

def func_a(q):
    q.put(3)
    q.put(2)
    q.put(1)

def func_b(q):
    v = q.get()
    print 'func_b prints:', v
    v = q.get()
    print 'func_b prints:', v
    v = q.get()
    print 'func_b prints:', v

if __name__ == '__main__':
    q = multiprocessing.Queue()
    p1 = multiprocessing.Process(target = func_a, args = (q,))
    p1.start()
    p2 = multiprocessing.Process(target = func_b, args = (q,))
    p2.start()
    p1.join()
    p2.join()

当我运行它时，它会打印：

func_b prints: 3
func_b prints: 2
func_b prints: 1
于 2012-04-12T08:21:25.563 回答