เป็นไปได้ไหมที่จะเริ่มกระบวนการ Pool ตามลำดับ?

ตามเอกสารประกอบ ไม่มีการควบคุมกระบวนการที่รวบรวมไว้ดังกล่าว อย่างไรก็ตาม คุณสามารถจำลองมันด้วยการล็อคได้:

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 ของคุณจะยังคงเริ่มต้นพร้อมกัน สิ่งที่ฉันหมายถึงคือคุณไม่สามารถควบคุมได้ว่ากระบวนการใดที่จะเริ่มดำเนินการโทรกลับก่อน แต่อย่างน้อยคุณก็ได้รับความล่าช้า สิ่งนี้ทำให้ผู้ปฏิบัติงานแต่ละคน "เริ่มต้น" อย่างมีประสิทธิภาพ (แต่จริงๆ แล้ว ดำเนินต่อไป) ในช่วงเวลาที่กำหนด

การแก้ไขที่เกิดจากการสนทนาด้านล่าง:

โปรดทราบว่าใน Windows ไม่สามารถสืบทอดการล็อกจากกระบวนการหลักได้ แต่คุณสามารถใช้ multiprocessing.Manager().Lock() เพื่อสื่อสารอ็อบเจ็กต์ล็อกโกลบอลระหว่างกระบวนการต่างๆ แทน (แน่นอนว่ามีค่าใช้จ่าย IPC เพิ่มเติม) จำเป็นต้องเริ่มต้นวัตถุล็อคส่วนกลางในแต่ละกระบวนการเช่นกัน สิ่งนี้จะมีลักษณะดังนี้:

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

คุณทำอะไรง่ายๆ แบบนี้ไม่ได้:

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)

ผลลัพธ์

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

คุณลองกำหนดฟังก์ชันที่ให้ค่าของคุณช้าๆ ได้ไหม

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

แล้ว:

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

ฉันยังไม่ได้ทดสอบ ดังนั้นฉันจึงไม่แน่ใจ แต่ลองดูก่อน

ฉันไม่สามารถรับคำตอบการล็อคให้ทำงานได้ด้วยเหตุผลบางประการ ดังนั้นฉันจึงใช้วิธีนี้ ฉันรู้ว่าคำถามนี้เก่า แต่อาจมีคนอื่นประสบปัญหาเดียวกัน

โดยจะวางกระบวนการทั้งหมดที่คล้ายกับโซลูชันการล็อค แต่จะเข้าสู่โหมดสลีปก่อนทำงานตามหมายเลขชื่อกระบวนการ

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

เนื่องจากชื่อที่กำหนดให้กับกระบวนการดูเหมือนจะไม่ซ้ำกันและเพิ่มขึ้น สิ่งนี้จะดึงจำนวนของกระบวนการและเข้าสู่โหมดสลีปตามนั้น SpawnPoolWorker-1 นอน 1 * 5 วินาที SpawnPoolWorker-2 นอน 2 * 5 วินาที เป็นต้น