Bagaimana untuk Berkongsi Barisan Hasil Antara Pelbagai Proses dalam Python?

Cara Berkongsi Barisan Hasil Antara Pelbagai Proses

Apabila bekerja dengan proses pekerja tak segerak menggunakan modul pemprosesan berbilang apply_async () fungsi, adalah penting untuk mempertimbangkan cara berkongsi baris gilir dengan selamat. Ralat "RuntimeError: Objek baris gilir hanya perlu dikongsi antara proses melalui warisan" menyerlahkan keperluan untuk melepasi baris gilir dengan cara yang menghalang isu penjerukan/nyahjeruk.

Untuk menyelesaikannya, kami boleh memanfaatkan pemproses berbilang.Pengurus () kelas, yang menyediakan cara untuk mengurus objek dan menjadikannya boleh diakses oleh pekerja yang berbeza.

<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, kami mencipta objek Pengurus (m) dan menggunakannya untuk menguruskan baris gilir (q). Dengan berbuat demikian, kami mencipta segmen memori kongsi yang membenarkan berbilang proses mengakses baris gilir dengan selamat, walaupun dalam senario tak segerak.

Atas ialah kandungan terperinci Bagaimana untuk Berkongsi Barisan Hasil Antara Pelbagai Proses dalam Python?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!