Python 多处理内存使用

优化Python多进程内存使用的方法

python
from multiprocessing import Process, Value
def worker(shared_value):
    for _ in range(1000000):
        shared_value.value += 1
if __name__ == '__main__':
    shared_val = Value('i', 0)
    processes = [Process(target=worker, args=(shared_val,)) for _ in range(4)]
    for process in processes:
        process.start()
    for process in processes:
        process.join()
    print("Final shared value:", shared_val.value)

python
from multiprocessing import Process, Value
import mmap
def worker(mmap_file, offset):
    for _ in range(1000000):
        current_value = int.from_bytes(mmap_file[offset:offset+4], byteorder='little')
        new_value = current_value + 1
        mmap_file[offset:offset+4] = new_value.to_bytes(4, byteorder='little')
if __name__ == '__main__':
    with mmap.mmap(-1, 4, access=mmap.ACCESS_WRITE) as mmap_file:
        mmap_file.write(b'%%x00%%x00%%x00%%x00')  # Initialize with zero
        processes = [Process(target=worker, args=(mmap_file, 0)) for _ in range(4)]
        for process in processes:
            process.start()
        for process in processes:
            process.join()
        mmap_file.seek(0)
        final_value = int.from_bytes(mmap_file.read(4), byteorder='little')
        print("Final shared value:", final_value)