Python：スレッドは一度しか起動できません。

Question

私はPythonでスレッディングを行いたいです。私は100単語あり、6つの異なるリンクにそれらを入れたい。リンクの1つが準備が整っていれば、リンクが新しい単語を得ることができます。これは他のスレッドがまだ作業中の最初の単語を持っている間、これ。私の完全なプログラムは、100個のキーワードが完了したときに、より多くのコードを最初に実行できるようにする必要があります。私は、現時点ではエラーが出る

threads = [] 

def getresults(seed): 
    for link in links: 
     t = threading.Thread(target=getLinkResult, args = (suggestengine, seed)) 
     threads.append(t) 
    for thread in threads: 
     thread.start() 

for seed in tqdm: 
    getresults(seed + a) 
    getresults(seed + b) 

for thread in threads: 
    thread.join() 

#code that should happen after 

： スレッドが一度だけ

Answer 1

あなたが二回getresultsを呼び出している開始することができ、かつ両方の時間が、彼らは同じグローバルthreadsリストを参照する私は、次のコードを持っています。つまり、getresultsを初めて呼び出すと、スレッドが開始されます。

2回目にそれらを呼び出すと、既に実行中の以前のスレッドに.start()メソッドが再び呼び出されます。

ローカルスレッドとしてgetresultsのスレッドを開始してから、それらをグローバルthreadsリストに追加する必要があります。

次の操作を行うことができますが：

for thread in threads: 
    if not thread.is_alive(): 
     thread.start() 

1つ以上のスレッドが既に終了してきたかもしれないので、再び開始されるので、同じエラーを引き起こすとして、それは問題を解決していません。

Answer 2

エラーは明示的です。スレッドを2回起動しますが、そうしないでください。

getresults(seed + a) 
getresults(seed + b) 

これらの呼び出しを並べ替えると、スレッドのループが2回開始されます。あなたがしたいことを正しく行うには、thread pool and a task queueを作成してください。基本的には、処理する単語のリストとミューテックスが必要です。各スレッドはmutexをロックし、単語の読み書きを解除し、その単語のロックを解除して処理します。

Answer 3

あなたのgetresults

threads = [] 

def getresults(seed): 
    local_threads = [] 
    for link in links: 
     t = threading.Thread(target=getLinkResult, args = (suggestengine, seed)) 
     local_threads.append(t) 
     threads.append(t) 
    for thread in local_threads: 
     thread.start() 

for seed in tqdm: 
    getresults(seed + a) 
    getresults(seed + b) 

for thread in threads: 
     thread.join()