同步不同频率的定时并行进程

import multiprocessing
import time

# 共享数据
shared_data = multiprocessing.Value('i', 0)

# 锁
lock = multiprocessing.Lock()

def task1():
    global shared_data
    while True:
        with lock:
            shared_data.value += 1
        time.sleep(1)

def task2():
    global shared_data
    while True:
        with lock:
            print(f"Shared data: {shared_data.value}")
        time.sleep(2)

if __name__ == "__main__":
    p1 = multiprocessing.Process(target=task1)
    p2 = multiprocessing.Process(target=task2)
    
    p1.start()
    p2.start()
    
    p1.join()
    p2.join()

import threading
import time

class TimingWheel:
    def __init__(self, interval):
        self.interval = interval
        self.wheel = [[] for _ in range(interval)]
        self.current_tick = 0
        self.lock = threading.Lock()
    
    def add_task(self, delay, task):
        tick = (self.current_tick + delay) % self.interval
        with self.lock:
            self.wheel[tick].append(task)
    
    def tick(self):
        with self.lock:
            tasks = self.wheel[self.current_tick]
            self.wheel[self.current_tick] = []
        for task in tasks:
            task()
        self.current_tick = (self.current_tick + 1) % self.interval

def task1():
    print("Task 1 executed")

def task2():
    print("Task 2 executed")

if __name__ == "__main__":
    timing_wheel = TimingWheel(interval=10)
    
    timing_wheel.add_task(delay=3, task=task1)
    timing_wheel.add_task(delay=5, task=task2)
    
    while True:
        timing_wheel.tick()
        time.sleep(1)