如何在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)