質問編集履歴
3
code changed
test
CHANGED
|
File without changes
|
test
CHANGED
|
@@ -8,20 +8,23 @@
|
|
|
8
8
|
import threading
|
|
9
9
|
import time
|
|
10
10
|
|
|
11
|
-
def
|
|
11
|
+
def login(queue, driver_num):
|
|
12
12
|
while True:
|
|
13
13
|
task = queue.get()
|
|
14
14
|
time.sleep(2)
|
|
15
15
|
queue.task_done()
|
|
16
|
-
print(f'driver{driver_num} : task{task}')
|
|
16
|
+
print(f'driver{driver_num} : task{task}')
|
|
17
17
|
|
|
18
18
|
queue = queue.Queue()
|
|
19
19
|
for driver_num in range(1,4):
|
|
20
|
-
thread = threading.Thread(target=
|
|
20
|
+
thread = threading.Thread(target=login, args=(queue, driver_num,), daemon=True)
|
|
21
21
|
thread.start()
|
|
22
22
|
|
|
23
|
+
f=open('data.txt')
|
|
23
|
-
|
|
24
|
+
data_list=f.read()
|
|
25
|
+
for data in data_list.split('\n'):
|
|
26
|
+
if data!='':
|
|
24
|
-
queue.put(ta
|
|
27
|
+
queue.put(data)
|
|
25
28
|
queue.join()
|
|
26
29
|
```
|
|
27
30
|
|
2
code added
test
CHANGED
|
File without changes
|
test
CHANGED
|
@@ -3,7 +3,7 @@
|
|
|
3
3
|
どのようにすれば、queueをsubprocessの引数にできるのでしょうか？
|
|
4
4
|
アドバイスいただきたいです。
|
|
5
5
|
|
|
6
|
-
```
|
|
6
|
+
```solved_code.py
|
|
7
7
|
import queue
|
|
8
8
|
import threading
|
|
9
9
|
import time
|
1
added code
test
CHANGED
|
File without changes
|
test
CHANGED
|
@@ -2,6 +2,28 @@
|
|
|
2
2
|
引数でqueueを送ろうとしたのですが、エラーになります。
|
|
3
3
|
どのようにすれば、queueをsubprocessの引数にできるのでしょうか？
|
|
4
4
|
アドバイスいただきたいです。
|
|
5
|
+
|
|
6
|
+
```解決後コード
|
|
7
|
+
import queue
|
|
8
|
+
import threading
|
|
9
|
+
import time
|
|
10
|
+
|
|
11
|
+
def test(queue, driver_num):
|
|
12
|
+
while True:
|
|
13
|
+
task = queue.get()
|
|
14
|
+
time.sleep(2)
|
|
15
|
+
queue.task_done()
|
|
16
|
+
print(f'driver{driver_num} : task{task}')
|
|
17
|
+
|
|
18
|
+
queue = queue.Queue()
|
|
19
|
+
for driver_num in range(1,4):
|
|
20
|
+
thread = threading.Thread(target=test, args=(queue, driver_num,), daemon=True)
|
|
21
|
+
thread.start()
|
|
22
|
+
|
|
23
|
+
for task in range(1,11):
|
|
24
|
+
queue.put(task)
|
|
25
|
+
queue.join()
|
|
26
|
+
```
|
|
5
27
|
|
|
6
28
|
```ここに言語を入力
|
|
7
29
|
import subprocess
|