Bagaimana untuk Berkongsi Baris Antara Berbilang Proses Pekerja Asynchronous dalam Multiprocessing?

Berkongsi Hasil Merentas Pelbagai Proses

Dalam pelbagai pemprosesan, perkongsian sumber, seperti baris gilir, antara proses yang berbeza boleh menjadi satu cabaran. Artikel ini meneroka cara berkongsi baris gilir hasil antara berbilang proses pekerja tak segerak menggunakan fungsi apply_async.

Kod sampel yang disediakan, menggunakan berbilang pemprosesan.Proses, gagal disebabkan oleh pengehadan perkongsian objek baris gilir merentas proses melalui warisan. Untuk mengatasi sekatan ini, kelas multiprocessing.Manager menawarkan penyelesaian.

Menggunakan multiprocessing.Manager

multiprocessing.Manager menyediakan cara untuk mencipta dan mengurus objek yang boleh dikongsi merentasi proses. Kod berikut menunjukkan cara menggunakan Pengurus untuk berkongsi baris gilir antara proses pekerja:

<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>

Dengan menggunakan m.Queue() dan bukannya multiprocessing.Queue(), baris gilir dicipta dan diuruskan oleh objek Manager . Ini membolehkan proses pekerja mengakses dan mengubah suai baris gilir tanpa menghadapi ralat "Objek giliran hanya boleh dikongsi antara proses melalui warisan".

Atas ialah kandungan terperinci Bagaimana untuk Berkongsi Baris Antara Berbilang Proses Pekerja Asynchronous dalam Multiprocessing?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!