如何在python中实现类似Java的异步行为？

Question

我知道如何实现异步操作在Java中这样

实例化一个新的话题 - >线程做费时的东西（磁盘IO或网络活动） - >线程完成其工作，并通过结果到主线程

我想在python中做同样的事情，但找不到方法... 我已阅读约async和await,multiprocessing.Pool。对于如何实现同样的目标，我也没有明确的想法。

我发现的最近的方法是multiprocessing.Pool.apply_async(Callable,Iterable,Callback)。但这个东西不能在类中实例化，因为它需要包装在if __name__=="__main__"中，而__name__是我的类名。

任何优雅的方式来在Python中做异步？ 谢谢！

Answer 1

线程基础

看看在threading模块。

一个例子：

from threading import Thread 

# instanciate a new thread 
t = Thread(target=my_task) 
# let it do the time-consuming stuff 
t.start() 
# do extra stuff while t is working 
do_extra_stuff() 
# wait for t to finish 
t.join() 

获取任务结果

不过，如果你想从my_task一个值，你需要要么使用全局变量，可变参数或包裹你的任务进入一个等级Thread。

下面是用包装类的例子：

class MyThread(Thread): 

    def __init__(self, *args, **kwargs): 
     super().__init__(*args, **kwargs) 
     self.result = None 

    def run(self): # this is the Thread method you need to override 
     # the time consuming stuff 
     self.result = some_result 

# same as before, but using the new class, so no need to specify target. 
t = MyThread() 
t.start() # will call t.run() for you. Never call t.run yourself (you'll lose every benefit from using Thread) 
t.join() # wait for t to be finished before getting result 
print(t.result) 

传递参数

要将参数传递任务（包括回调），你可以把它们作为类字段，并在填补他们construcor，或使用args kwarg从Thread的construcor，像这样：

t = Thread(target=task_with_parametters, args=(arg1, arg2)) 

Thread无线我会打电话task_with_parametters像这样：

task_with_parametters(arg1, arg2)