解决访问冲突

import threading

lock = threading.Lock()
shared_resource = 0

def thread_task():
    global shared_resource
    with lock:
        # Critical section
        shared_resource += 1

threads = [threading.Thread(target=thread_task) for _ in range(10)]
for thread in threads:
    thread.start()
for thread in threads:
    thread.join()

print(shared_resource)  # Output should be 10

import threading
import atomic

shared_resource = atomic.AtomicInteger(0)

def thread_task():
    shared_resource.incrementAndGet()

threads = [threading.Thread(target=thread_task) for _ in range(10)]
for thread in threads:
    thread.start()
for thread in threads:
    thread.join()

print(shared_resource.get())  # Output should be 10

import threading

semaphore = threading.Semaphore(3)  # Allow 3 threads to access the resource concurrently

def thread_task():
    with semaphore:
        # Critical section
        print(f"Thread {threading.current_thread().name} is working")

threads = [threading.Thread(target=thread_task) for _ in range(10)]
for thread in threads:
    thread.start()
for thread in threads:
    thread.join()

import threading

condition = threading.Condition()
shared_resource = []

def producer():
    for i in range(5):
        with condition:
            shared_resource.append(i)
            condition.notify()  # Notify waiting threads

def consumer():
    while True:
        with condition:
            while not shared_resource:
                condition.wait()  # Wait for notification
            item = shared_resource.pop(0)
            print(f"Consumed {item}")

producer_thread = threading.Thread(target=producer)
consumer_thread = threading.Thread(target=consumer)

producer_thread.start()
consumer_thread.start()

producer_thread.join()
consumer_thread.join()