python で、queueをsubprocessの引数にして実行したい

Question

subprocess を使って、 python のプログラムを３度実行するのですが、その際に３つのプログラムから一つのqueueを参照したいです。
引数でqueueを送ろうとしたのですが、エラーになります。
どのようにすれば、queueをsubprocessの引数にできるのでしょうか？
アドバイスいただきたいです。

import queue
import threading
import time

def login(queue, driver_num):
    while True:
        task = queue.get()
        time.sleep(2)
        queue.task_done()
        print(f'driver{driver_num} : task{task}')   

queue = queue.Queue()
for driver_num in range(1,4):
    thread = threading.Thread(target=login, args=(queue, driver_num,), daemon=True)
    thread.start()

f=open('data.txt')
data_list=f.read()
for data in data_list.split('\n'):
    if data!='':
        queue.put(data)  
queue.join()

import subprocess
import queue

screenshot_home_queue=queue.Queue()
f=open('data.txt')
data_list=f.read()
f.close()
for data in data_list.split('\n'):
    screenshot_home_queue.put(data)

cmd='python test.py 1 {}'.format(screenshot_home_queue)
subprocess.Popen(cmd +'&',shell=True) 
subprocess.Popen(cmd +'&',shell=True) 
subprocess.Popen(cmd +'&',shell=True) 

/bin/sh: -c: line 0: syntax error near unexpected token `newline'
/bin/sh: -c: line 0: `python test.py 1 <queue.Queue object at 0x7fe2dbd8e370>'

Answer 1

ターミナル画面で、このcmd変数の内容をタイプしてそれが実行できるのかを確認されてはどうでしょうか

Comments

[alizona]

queueはターミナル上で作成できるのですか？

[y_waiwai]

それで実行できないとあなたがお考えなら、そのエラーメッセージもその対処法ってのも自明なのでは

[alizona]

その場合、３つの実行されたpython programから一つのqueueを参照したい場合は、どのようにすればいいのでしょうか？

queueクラスを作り、関数内でqueueをgolobalで作成して、python porguramから、アクセスしようとしたのですが、global変数でも複数のpython programの中では共有できませんでした。

[alizona]

tes.py を subprocessで呼び出すのではなく、python でthreadingを使って、test()を呼び出すことにしました。
ありがとうございました。

[alizona]

#-------------------------------------------------------test.py-------------------------------------------------------
import queue
import threading
import time

queue=queue.Queue()

def login(driver_num, q):
while not q.empty():
task = q.get()
#q.task_done()
print(str(task) + ' : '+str(driver_num))
time.sleep(5)

def create_thread(driver_num):
thread = threading.Thread(target=login, args=(driver_num,queue,))
thread.start()

def init():
global queue
for num in range(1,11):
queue.put(num)

create_thread(1)
create_thread(2)
#queue.join()

#-------------------------------------------------------manage.py-------------------------------------------------------
from test import create_thread
from test import init
import time

init()
time.sleep(10)
create_thread(3)