回答編集履歴

コード修正

2020/06/24 02:45

投稿

スコア1137

test CHANGED Viewed

@@ -1,6 +1,6 @@
 たとえば、下記コードで、下から2行目をwait=Trueとすると、すべてのタスクが終了してから、「すべてのタスクが完了しました」と表示されますが、
-wait=Falseに変えると、「すべてのタスクが完了しました」と表示されてから「タスク#{num} が完了しました.」が順次表示されます。
+wait=Falseに変えると、先に「すべてのタスクが完了しました」と表示されてから「タスク#{num} が完了しました.」が順次表示されます。
@@ -16,13 +16,11 @@
 ```
-from concurrent.futures import ThreadPoolExecutor, as_completed
+from concurrent.futures import ThreadPoolExecutor
 import time
 from datetime import datetime
-import random
 th = ThreadPoolExecutor(max_workers=5)

修正

2020/06/24 02:45

投稿

スコア1137

test CHANGED Viewed

@@ -1,6 +1,6 @@
-たとえば、下記コードで、下から2行目をwait=Trueとすると、すべてのタスクが終了してから、「all finished」が表示されますが、
+たとえば、下記コードで、下から2行目をwait=Trueとすると、すべてのタスクが終了してから、「すべてのタスクが完了しました」と表示されますが、
-wait=Falseに変えると、「all finished」が表示されてから「task #{num} finished」が順次表示されます。
+wait=Falseに変えると、「すべてのタスクが完了しました」と表示されてから「タスク#{num} が完了しました.」が順次表示されます。

コード修正

2020/06/24 02:44

投稿

スコア1137

test CHANGED Viewed

@@ -38,21 +38,19 @@
     interval = num*2
-    print_with_time(f"task #{num}: set interval= {interval}")
+    print_with_time(f"タスク#{num}: 完了まで {interval}秒")
     time.sleep(interval)
-    print_with_time(f"task #{num} finished.")
+    print_with_time(f"タスク#{num} が完了しました.")
-futures = []
 for i in range (5):
-    futures.append(th.submit(task, i+1))
+    th.submit(task, i+1)
@@ -60,7 +58,7 @@
-print_with_time("all finished")
+print_with_time("＜＜＜すべてのタスクが完了しました＞＞＞")

2020/06/24 02:42

投稿

スコア1137

test CHANGED Viewed

@@ -6,9 +6,11 @@
-wait=Trueにすると、submitしたすべてのタスクが完了するまで、submit元のスレッドでは何も処理できません。これは不便と思うかもしれませんが、submitしたすべてのタスクが共通のリソースを扱っている場合等、プログラムを安全に操作する場合には必要になることもあります。
+wait=Trueにすると、shutdown()関数でいったん止まり、submitしたすべてのタスクが完了するまで（submit元のスレッドでは）処理が進みません。
+一方、wait=Falseにすると、submitしたタスクの完了状態に関係なく、shutdown()関数からすぐに戻り、submit元のスレッドで処理を継続することができます。
+（使い分けはどのようなプログラムにしたいかによります）