Python：スレッド/マルチプロセッシングがCPUを100％使用しないようにするにはどうすればよいですか？

Question

私は無限の時間の間、毎秒7つのデバイスからデータを読み取るコードを持っています。各ループは、7つのプロセスを開始するスレッドが作成されます。各プロセスが完了すると、プログラムは1秒間待ってから再開します。コードスニペットは次のとおりです。

def all_thread(): #function that handels the threading 
    thread = threading.Thread(target=all_process) #prepares a thread for the devices 
    thread.start() #starts a thread for the devices 

def all_process(): #function that prepares and runs processes 
    processes = [] #empty list for the processes to be stored 
    while len(gas_list) > 0: #this gaslist holds the connection information for my devices 
     for sen in gas_list: #for each sen(sensor) in the gas list 
      proc = multiprocessing.Process(target=main_reader, args=(sen, q)) #declaring a process variable that sends the gas object, value and queue information to reading function 
      processes.append(proc) #adding the process to the processes list 
      proc.start() #start the process 
     for sen in processes: #for each sensor in the processes list 
      sen.join() #wait for all the processes to complete before starting again 
     time.sleep(1) #wait one second 

ただし、これは私のCPUの100％を使用しています。これは、スレッディングとマルチプロセッシングの設計によるものか、あるいは悪いコーディングによるものなのでしょうか？ CPU使用量を制限できる方法はありますか？ありがとう！

アップデート：私は質問にそれを置くよう

コメントはmain_reader()機能を言及しました。すべてのデータは各デバイスで読み取られ、すべてのデータが取り込まれ、リストに追加されます。リストはキューに入れられ、tkinter GUIに表示されます。あなたがコメントで状態として

def main_reader(data, q): #this function reads the device which takes less than a second 
    output_list = get_registry(data) #this function takes the device information, reads the registry and returns a list of data 
    q.put(output_list) #put the output list into the queue 

Answer 1

、あなたのmain_readerは、プロセス作成オーバーヘッドがあなたの問題を引き起こす可能性を意味し、実行するのはほんの一瞬を取ります。

multiprocessing.Poolの例を示します。これにより、作業者のプールが作成され、タスクがタスクに送信されます。プロセスは一度だけ起動され、無限ループである場合はシャットダウンまたは結合されません。プールをシャットダウンしたい場合は、プールに参加したり閉じたりすることで行うことができます（そのドキュメントを参照）。

from multiprocessing import Pool, Manager 
from time import sleep 
import threading 
from random import random 

gas_list = [1,2,3,4,5,6,7,8,9,10] 

def main_reader(sen, rqu): 
    output = "%d/%f" % (sen, random()) 
    rqu.put(output) 


def all_processes(rq): 
    p = Pool(len(gas_list) + 1) 
    while True: 
     for sen in gas_list: 
      p.apply_async(main_reader, args=(sen, rq)) 

     sleep(1) 

m = Manager() 
q = m.Queue() 
t = threading.Thread(target=all_processes, args=(q,)) 
t.daemon = True 
t.start() 

while True: 
    r = q.get() 
    print r 

これが解決しない場合は、さらに深く掘り下げてください。私はまず、あなたの無限ループの中で睡眠を10秒以上に増やします。これにより、プログラムの動作を監視することができます。 CPUがしばらくピークを迎えてから10秒ほど落ち着くと、main_readerに問題があることがわかります。まだ100％であれば、あなたの問題は他の場所になければなりません。

プログラムのこの部分に問題がない可能性はありますか？あなたはメインプログラムが何か他のことをしていることを示す、スレッド内でこれをすべて起動するようです。 CPUをピークにする何か他のものにすることはできますか？