子級任務:

說明: 前面學習的任務呼叫基本上已夠用,但有時業務場景可能需要任務關聯,且子任務可能需要父任務為其傳遞一些必要引數,此時可通過func.subtask或簡寫func.s實現,子任務物件依然可以呼叫任務物件的API,delay和apply_async,但和常規呼叫不同的是子任務呼叫時傳遞的引數加生成子任務時初始化引數的才是最終任務的引數,所以子任務在呼叫時就不需要再重複傳遞子任務初始化時的引數了.

注意: send_mail.subtask(('sub', 'msg'), countdown=1)或send_mail.s('sub', 'msg', countdown=1)返回的是Signature物件,此物件攜帶生成子任務時的引數,且可呼叫任務物件的API,當呼叫時,傳遞的引數被提前.

原語操作:

# 使組式:

說明: group內部使用列表生成式生成了10個子任務,生成時且提供了一個引數,當呼叫group('usr', 'sub')時其實是遍歷group內部的所有子任務呼叫其.delay('usr', 'sub'),所以是併發非同步執行的,上面說過,呼叫時傳遞的引數會被提前,所以其實最終的引數順序是'usr', 'sub', 'msg_{0}'.format(i),非同步返回的是GroupResult物件,如果要獲取每個子任務的結果,可通過同步阻塞的get方法獲取.

# 使鏈式:

說明: chain內部兩個鏈式子任務,|表示前一個的輸出作為另一個的輸入,當呼叫chain(...)(5)時,其實是首先呼叫add.s(2).delay(5)計算出結果為7,然後|傳遞作為add.s(1)的輸入,其實是呼叫add.s(1).delay(7)

計算出結果為8,非同步返回的是AsyncResult物件,可通過同步阻塞的get方法獲取,鏈式操作還有一個特別的地方可通過result.parent.get()獲取上層結果.

# 使回撥:

說明: chord和group類似,只是在此基礎上加了個回撥,當呼叫get方法時會對,第一個引數必須是一個包含子任務的可迭代物件,第二個為可回撥函式或方法,會自動接收提前引數,其實用chain和group也可以利用如上方式實現類似回撥.