multiprocessingでQueueのputとgetを別プロセスで回しながらやるやつ
import time import math from multiprocessing import Process, Queue, cpu_count import queue as pyqueue def worker(q): while True: try: # なにか処理 _ = q.get(timeout=15) except pyqueue.Empty: break def main(q): for i in range(1000): q.put(i) if __name__ == "__main__": q = Queue(maxsize=1000) p = Process(t…
2021/03/23 19:49
