如何判断所有线程任务是否已经完成？

[zenwan]

import vthread
import time

alist=[]
@vthread.pool(3,join=False)
def some(a, b, c):
    time.sleep(1)
    s = a + b + c
    alist.append(s)

def foo():
    for i in range(10):
         some(i, i, i)
print(alist)

什么时候获取alist?

[cilame]

import vthread
import time

alist=[]
@vthread.pool(3,join=False)
def some(a, b, c):
    time.sleep(1)
    s = a + b + c
    alist.append(s)

def foo():
    for i in range(10):
         some(i, i, i)

foo() # 你的代码少了函数执行
time.sleep(4) # 如果不考虑其他，光凭意念的话，你完全可以用sleep来等函数执行完
print(alist)

关于多线程，任务的结果一般是用管道来实现会更好一点。
下面的代码，这样或许会更安全。

import vthread
import time
import queue

ls = [1,44,32,45,67,88,99,100,55]

q = queue.Queue()

@vthread.pool(3)
def func(i):
    try:
        r = i + i + i
        time.sleep(1)
        if r == 3:
            raise
    except:
        r = None # 按照数量的put和get需要注意异常的消费
    print(r) # log
    q.put(r)
        

for i in ls:
    func(i)

alist = [q.get() for i in range(len(ls))]
print(alist)

[SunYong0821]

import vthread
import time

alist=[]
@vthread.pool(3,join=False)
def some(a, b, c):
    time.sleep(1)
    s = a + b + c
    alist.append(s)

def foo():
    for i in range(10):
         some(i, i, i)

foo() # 你的代码少了函数执行
time.sleep(4) # 如果不考虑其他，光凭意念的话，你完全可以用sleep来等函数执行完
print(alist)

关于多线程，任务的结果一般是用管道来实现会更好一点。
下面的代码，这样或许会更安全。

import vthread
import time
import queue

ls = [1,44,32,45,67,88,99,100,55]

q = queue.Queue()

@vthread.pool(3)
def func(i):
    try:
        r = i + i + i
        time.sleep(1)
        if r == 3:
            raise
    except:
        r = None # 按照数量的put和get需要注意异常的消费
    print(r) # log
    q.put(r)
        

for i in ls:
    func(i)

alist = [q.get() for i in range(len(ls))]
print(alist)

为什么不提供返回值？