質問編集履歴
2
再度質問を変更しました。
test
CHANGED
|
File without changes
|
test
CHANGED
|
@@ -1,3 +1,5 @@
|
|
|
1
|
+
```
|
|
2
|
+
|
|
1
3
|
from multiprocessing import Pool
|
|
2
4
|
|
|
3
5
|
from contextlib import closing
|
|
@@ -74,10 +76,14 @@
|
|
|
74
76
|
|
|
75
77
|
result_list_3 = map_result_3.get()
|
|
76
78
|
|
|
79
|
+
|
|
80
|
+
|
|
77
81
|
コード
|
|
78
82
|
|
|
79
83
|
```
|
|
80
84
|
|
|
81
85
|
これを実行したところ下記のエラーが出てしまいました。
|
|
82
86
|
|
|
87
|
+
|
|
88
|
+
|
|
83
|
-
starmap_async
|
|
89
|
+
AttributeError: 'Pool' object has no attribute 'starmap_async'
|
1
再度書きました。よろしくお願いします。
test
CHANGED
|
File without changes
|
test
CHANGED
|
@@ -48,19 +48,21 @@
|
|
|
48
48
|
|
|
49
49
|
|
|
50
50
|
|
|
51
|
+
|
|
52
|
+
|
|
51
53
|
initial_num_list = list(range(3))
|
|
52
54
|
|
|
53
55
|
with closing(Pool(4)) as p:
|
|
54
56
|
|
|
55
|
-
map_result_1 = p.map_async(
|
|
57
|
+
map_result_1 = p.starmap_async(
|
|
56
58
|
|
|
57
59
|
func=sample_func_1, iterable=initial_num_list)
|
|
58
60
|
|
|
59
|
-
map_result_2 = p.map_async(
|
|
61
|
+
map_result_2 = p.starmap_async(
|
|
60
62
|
|
|
61
63
|
func=sample_func_2, iterable=initial_num_list)
|
|
62
64
|
|
|
63
|
-
map_result_3 = p.map_async(
|
|
65
|
+
map_result_3 = p.starmap_async(
|
|
64
66
|
|
|
65
67
|
func=sample_func_3, iterable=initial_num_list)
|
|
66
68
|
|
|
@@ -72,8 +74,10 @@
|
|
|
72
74
|
|
|
73
75
|
result_list_3 = map_result_3.get()
|
|
74
76
|
|
|
77
|
+
コード
|
|
75
78
|
|
|
79
|
+
```
|
|
76
80
|
|
|
81
|
+
これを実行したところ下記のエラーが出てしまいました。
|
|
77
82
|
|
|
78
|
-
|
|
79
|
-
|
|
83
|
+
starmap_asyncで並列処理したいと思います。
|