Apakah mungkin untuk memulai proses Pool secara berurutan?

Menurut dokumentasi, tidak ada kontrol atas proses gabungan. Namun Anda dapat mensimulasikannya dengan kunci:

import multiprocessing
import time

lock = multiprocessing.Lock()

def worker(nr):
    lock.acquire()
    time.sleep(0.100)
    lock.release()
    print(nr)

numbers = [i for i in range(20)]

if __name__ == '__main__':
    multiprocessing.freeze_support()
    pool = multiprocessing.Pool(processes=3)
    results = pool.map(worker, numbers)
    pool.close()
    pool.join()

3 proses Anda masih akan dimulai secara bersamaan. Maksud saya adalah Anda tidak memiliki kendali atas proses mana yang mulai menjalankan panggilan balik terlebih dahulu. Tapi setidaknya Anda mendapatkan penundaan Anda. Hal ini secara efektif membuat setiap pekerja "memulai" (tetapi sebenarnya, melanjutkan) pada interval yang ditentukan.

Perubahan hasil diskusi di bawah ini:

Perhatikan bahwa di Windows tidak mungkin mewarisi kunci dari proses induk. Sebagai gantinya, Anda dapat menggunakan multiprocessing.Manager().Lock() untuk mengomunikasikan objek kunci global antar proses (tentu saja dengan overhead IPC tambahan). Objek kunci global juga perlu diinisialisasi dalam setiap proses. Ini akan terlihat seperti:

from multiprocessing import Process, freeze_support
import multiprocessing
import time
from datetime import datetime as dt

def worker(nr):
    glock.acquire()
    print('started job: {} at {}'.format(nr, dt.now()))
    time.sleep(1)
    glock.release()
    print('ended   job: {} at {}'.format(nr, dt.now()))

numbers = [i for i in range(6)]

def init(lock):
    global glock
    glock = lock

if __name__ == '__main__':
    multiprocessing.freeze_support()
    lock = multiprocessing.Manager().Lock()
    pool = multiprocessing.Pool(processes=3, initializer=init, initargs=(lock,))
    results = pool.map(worker, numbers)
    pool.close()
    pool.join()

Tidak bisakah kamu melakukan sesuatu yang sederhana seperti ini:

from multiprocessing import Process
from time import sleep

def f(n):
    print 'started job: '+str(n)
    sleep(3)
    print 'ended job: '+str(n)

if __name__ == '__main__':
    for i in range(0,100):
        p = Process(target=f, args=(i,))
        p.start()
        sleep(1)

Hasil

started job: 0
started job: 1
started job: 2
ended job: 0
started job: 3
ended job: 1
started job: 4
ended job: 2
started job: 5

bisakah Anda mencoba mendefinisikan fungsi yang menghasilkan nilai Anda secara perlahan?

def get_numbers_on_delay(numbers, delay):
    for i in numbers:
        yield i
        time.sleep(delay)

kemudian:

results = pool.map(worker, get_numbers_on_delay(numbers, 5))

saya belum mengujinya, jadi saya tidak yakin, tapi cobalah.

Saya tidak bisa mendapatkan jawaban penguncian untuk beberapa alasan jadi saya menerapkannya dengan cara ini. Saya menyadari pertanyaannya sudah lama, tapi mungkin orang lain memiliki masalah yang sama.

Ini memunculkan semua proses yang mirip dengan solusi penguncian, tetapi tertidur sebelum bekerja berdasarkan nomor nama prosesnya.

from multiprocessing import current_process
from re import search
from time import sleep

def worker():
    process_number = search('\d+', current_process().name).group()
    time_between_workers = 5
    sleep(time_between_workers * int(process_number))
    #do your work here

Karena nama yang diberikan pada proses tampak unik dan bertahap, maka ini akan mengambil jumlah proses dan tidur berdasarkan nama tersebut. SpawnPoolWorker-1 tidur 1 * 5 detik, SpawnPoolWorker-2 tidur 2 * 5 detik, dll.