[心得] 支援顯示Abort/Failed的WaitAll
MMA有個asynchronous computing的功能叫ParallelSubmit
它不僅可以配合WaitAll/WaitNext做非同步運算,還附贈精美status icon來提示工作狀態
基本上它的icon有4種state
1. Ready : work item在queue中等待
2. Running : 送到parallel kernel中正在跑...
3. Received/Finished : 跑完了已經回傳output到主kernel
4. Failed : 這個work item GG惹 (通常是因為AbortKernels[])
最後的Failed很怪, 如果乖乖在item裡送出Abort就只是終止這個item並回傳$Aborted
由於這個item還是正常地完成了, status icon會辨識為Received/Finished而非直覺上的
Failed
要跳到Failed state一定得要從MMA的asynchronous queue本身下手才有用
例如用 Parallel`Developer`ResetQueues直接把queue中的ready states清空
或是在WaitNext/WaitAll執行work item的過程中直接在front end abort
也就是說這個Failed state基本上沒用OTZ
為了增加它的用途我用doc裡提到的"重複跑同一個work item兩次會跳到Failed state"的
特性做了一個可以自動在遇到$Failed或$Aborted時跳到Failed state的WaitAll
除此之外它也可以吃{$Failed/$Aborted, failed expression} 來提供CheckAbort的功能
(bag只是個container,不想有shadowing的話可以再包一層)
WaitAllBetter[F : {__EvaluationObject}] :=
CheckAbort[Block[{res = bag[], obj, queue = F, temp, out, Stepper},
Stepper = ({temp, obj, queue} = WaitNext[#];
res = {res, bag[temp]};
If[MemberQ[{$Failed, $Aborted}, #] & /@
Or[temp, Quiet@temp[[1]]], WaitAll[obj]];) &;
Do[Stepper[queue], {Length[F]}];
Flatten@res /. bag -> Sequence /. {$Failed | $Aborted, out_} ->
out], AbortKernels[]; Abort[]]
用這個function可以實作TimeConstraint的同時避免掉用Message產生洗版的問題
以ParallelSubmit MMA doc的Neat example為例
(PrintTemporary[#]; #) &@
Table[ParallelSubmit[{i}, If[# === $Aborted, {$Failed, TO[i]}, #] &@
TimeConstrained[Plus @@ FactorInteger[2^i - 1][[All, 2]], 4]],
{i, 220, 170, -1}];
WaitAllBetter[%]
跑起來比Message清楚多了~
--
※ 發信站: 批踢踢實業坊(ptt.cc), 來自: 140.112.4.190
※ 文章網址: https://www.ptt.cc/bbs/Mathematica/M.1477566697.A.C03.html
→
10/27 19:14, , 1F
10/27 19:14, 1F
→
10/27 19:15, , 2F
10/27 19:15, 2F
推
10/27 21:28, , 3F
10/27 21:28, 3F
→
10/27 21:30, , 4F
10/27 21:30, 4F
→
10/27 22:06, , 5F
10/27 22:06, 5F
→
10/27 22:53, , 6F
10/27 22:53, 6F
→
10/27 22:53, , 7F
10/27 22:53, 7F
→
10/27 23:09, , 8F
10/27 23:09, 8F
→
10/27 23:10, , 9F
10/27 23:10, 9F
推
10/28 10:12, , 10F
10/28 10:12, 10F
→
10/28 10:14, , 11F
10/28 10:14, 11F
→
10/28 10:15, , 12F
10/28 10:15, 12F
→
10/28 13:46, , 13F
10/28 13:46, 13F
→
10/28 13:47, , 14F
10/28 13:47, 14F
→
10/28 13:47, , 15F
10/28 13:47, 15F
→
10/28 13:48, , 16F
10/28 13:48, 16F
今天跑的時候發現原本的code會flatten結構,所以就重寫了code
WaitAllBetter = Function[{F},
CheckAbort[Block[{FailedExp},
WaitAll[F] //
(If[MemberQ[{$Failed, $Aborted}, #] & /@ Or[#, Quiet@#[[1]]],
WaitAll[F]];
# /. {$Failed | $Aborted, FailedExp_} -> FailedExp) &
], AbortKernels[]; Abort[]]
, {Listable}];
新版的code readability比較高, 也適用於list of lists的情況, 不過遇到header不是
List的時候就沒辦法及時跳轉Failed state,而且CheckAbort功能也可能會跟特殊的code
衝到
基本上就是避免先對EvaluationObject list做運算就對了@@
※ 編輯: AmibaGelos (140.112.4.190), 10/28/2016 13:56:10
Mathematica 近期熱門文章
PTT數位生活區 即時熱門文章