Bagaimana untuk Menyelesaikan Ralat \'Objek Baris Gilir Hanya Perlu Dikongsi Antara Proses Melalui Pewarisan\' dalam Multiprocessing?

Mengurus Baris Berkongsi dengan berbilang pemprosesan

Dalam modul berbilang pemprosesan Python, mencipta baris gilir dikongsi antara proses memerlukan pertimbangan yang teliti apabila menggunakan multiprocessing.apply_async() untuk memulakan proses pekerja tak segerak. "Objek giliran hendaklah hanya dikongsi antara proses melalui warisan." ralat berlaku apabila cuba menghantar baris gilir terus kepada pekerja.

Untuk menyelesaikan isu ini, gunakan multiprocessing.Pengurus untuk mengurus baris gilir dan menjadikannya boleh diakses oleh proses pekerja. multiprocessing.Manager menyediakan kaedah untuk mencipta objek pengurus yang mengawal dan menyerikan pelbagai jenis data dalam segmen memori yang dikongsi.

Coretan kod berikut menunjukkan cara berkongsi baris gilir antara berbilang proses pekerja menggunakan multiprocessing.Manager:

<code class="python">import multiprocessing

def worker(name, que):
    que.put("%d is done" % name)

if __name__ == '__main__':
    pool = multiprocessing.Pool(processes=3)
    m = multiprocessing.Manager()
    q = m.Queue()
    workers = pool.apply_async(worker, (33, q))</code>

Dalam contoh ini, multiprocessing.Manager() mencipta objek pengurus (m) yang mengurus data kongsi dan menyediakan objek proksi yang boleh dihantar kepada proses pekerja. Dengan memanggil m.Queue(), kami mencipta baris gilir yang diuruskan oleh pengurus, yang boleh diakses oleh semua proses pekerja. Pengurus kemudian menyerikan objek proksi dan menyerahkannya kepada pekerja, membolehkannya berkomunikasi dengan baris gilir dikongsi dengan selamat.

Atas ialah kandungan terperinci Bagaimana untuk Menyelesaikan Ralat \'Objek Baris Gilir Hanya Perlu Dikongsi Antara Proses Melalui Pewarisan\' dalam Multiprocessing?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!