Python实现双进程防止单点故障实例深度探究

import multiprocessing
# 共享状态
shared_data = multiprocessing.Value('i', 0)
# 进程函数
def process_function(shared_data):
    # 操作共享状态
    shared_data.value += 1
    print(f"Process ID: {multiprocessing.current_process().pid}, Shared Data: {shared_data.value}")
# 创建进程
process = multiprocessing.Process(target=process_function, args=(shared_data,))
process.start()
process.join()

import multiprocessing
import time
def process_function(shared_data):
    while True:
        # 模拟进程工作
        time.sleep(1)
        # 更新心跳
        shared_data.value = time.time()
# 创建进程
shared_data = multiprocessing.Value('d', time.time())
process = multiprocessing.Process(target=process_function, args=(shared_data,))
process.start()
# 主进程定期检查心跳
while True:
    time.sleep(2)
    if time.time() - shared_data.value > 3:
        print("Heartbeat lost! Restarting the process.")
        process.terminate()
        process.join()
        process = multiprocessing.Process(target=process_function, args=(shared_data,))
        process.start()

import multiprocessing
# 共享状态和锁
shared_data = multiprocessing.Value('i', 0)
data_lock = multiprocessing.Lock()
# 进程函数
def process_function(shared_data, data_lock):
    with data_lock:
        shared_data.value += 1
        print(f"Process ID: {multiprocessing.current_process().pid}, Shared Data: {shared_data.value}")
# 创建进程
process = multiprocessing.Process(target=process_function, args=(shared_data, data_lock))
process.start()
process.join()

import multiprocessing
import time
def process_function(shared_data, data_lock):
    while True:
        time.sleep(1)
        with data_lock:
            shared_data.value = time.time()
# 创建进程并维护重启逻辑
def create_process():
    process = multiprocessing.Process(target=process_function, args=(shared_data, data_lock))
    process.start()
    return process
process = create_process()
while True:
    time.sleep(2)
    if time.time() - shared_data.value > 3:
        print("Heartbeat lost! Restarting the process.")
        process.terminate()
        process.join()
        process = create_process()