Python中如何实现多线程同步？

import threading
import time

class SharedResource:
    def __init__(self):
        self.value = 0
        self.lock = threading.Lock()

    def increment(self):
        with self.lock:
            self.value += 1
            time.sleep(0.1)  # 模拟一些操作
            print(f"Value incremented to {self.value}")

def worker(shared_resource):
    for _ in range(5):
        shared_resource.increment()

if __name__ == "__main__":
    shared_resource = SharedResource()
    threads = []

    for i in range(2):
        t = threading.Thread(target=worker, args=(shared_resource,))
        threads.append(t)
        t.start()

    for t in threads:
        t.join()

    print(f"Final value: {shared_resource.value}")

import threading
import time
import random

class SharedQueue:
    def __init__(self):
        self.queue = []
        self.condition = threading.Condition()

    def produce(self, item):
        with self.condition:
            self.queue.append(item)
            print(f"Produced {item}")
            self.condition.notify_all()

    def consume(self):
        with self.condition:
            while not self.queue:
                self.condition.wait()
            item = self.queue.pop(0)
            print(f"Consumed {item}")
            return item

def producer(shared_queue):
    for i in range(5):
        time.sleep(random.random())
        shared_queue.produce(i)

def consumer(shared_queue):
    for _ in range(5):
        time.sleep(random.random())
        shared_queue.consume()

if __name__ == "__main__":
    shared_queue = SharedQueue()
    producer_thread = threading.Thread(target=producer, args=(shared_queue,))
    consumer_thread = threading.Thread(target=consumer, args=(shared_queue,))

    producer_thread.start()
    consumer_thread.start()

    producer_thread.join()
    consumer_thread.join()