ماژول thread_ – قفل کردن منابع مشترک

import _thread as thread
import time

# شمارنده مشترک
counter = 0

# قفل برای همگام‌سازی دسترسی به متغیر مشترک
lock = thread.allocate_lock()

# تابع افزایش شمارنده
def add(thread_id):
    global counter
    for _ in range(100):
        # قفل گرفتن برای دسترسی به متغیر مشترک
        lock.acquire()
        temp = counter
        temp += 1
        time.sleep(0.01)  # اضافه کردن یک خواب کوتاه برای تشدید شرایط رقابتی
        counter = temp
        print(f"Thread {thread_id}: {counter}")
        # قفل رها کردن بعد از استفاده
        lock.release()

def subtract(thread_id):
    global counter
    for _ in range(100):
        # قفل گرفتن برای دسترسی به متغیر مشترک
        lock.acquire()
        temp = counter
        temp -= 1
        time.sleep(0.01)  # اضافه کردن یک خواب کوتاه برای تشدید شرایط رقابتی
        counter = temp
        print(f"Thread {thread_id}: {counter}")
        # قفل رها کردن بعد از استفاده
        lock.release()

# ایجاد چندین نخ
thread.start_new_thread(add, (1,))
thread.start_new_thread(subtract, (2,))

# منتظر ماندن برای پایان نخ‌ها
time.sleep(5)

print(f"Final counter value: {counter}")

import _thread as thread
import time

# شمارنده مشترک
counter = 0

# قفل برای همگام‌سازی دسترسی به متغیر مشترک
lock = thread.allocate_lock()

# تابع افزایش شمارنده
def add(thread_id):
    global counter
    for _ in range(100):
        # قفل گرفتن برای دسترسی به متغیر مشترک
        lock.acquire()
        temp = counter
        temp += 1
        time.sleep(0.01)  # اضافه کردن یک خواب کوتاه برای تشدید شرایط رقابتی
        counter = temp
        print(f"Thread {thread_id}: {counter}")
        # قفل رها کردن بعد از استفاده
        lock.release()

def subtract(thread_id):
    global counter
    for _ in range(100):
        # قفل گرفتن برای دسترسی به متغیر مشترک
        lock.acquire()
        temp = counter
        temp -= 1
        time.sleep(0.01)  # اضافه کردن یک خواب کوتاه برای تشدید شرایط رقابتی
        counter = temp
        print(f"Thread {thread_id}: {counter}")
        # قفل رها کردن بعد از استفاده
        lock.release()

# ایجاد چندین نخ
thread.start_new_thread(add, (1,))
thread.start_new_thread(subtract, (2,))

# منتظر ماندن برای پایان نخ‌ها
time.sleep(5)

print(f"Final counter value: {counter}")

import time
import _thread as thread

# شمارنده مشترک
counter = 0

# قفل برای همگام‌سازی دسترسی به متغیر مشترک
lock = thread.allocate_lock()

# تابع افزایش شمارنده
def add(thread_id):
    global counter
    for _ in range(100):
        # قفل گرفتن برای دسترسی به متغیر مشترک با استفاده از with
        with lock:
            temp = counter
            temp += 1
            time.sleep(0.01)  # اضافه کردن یک خواب کوتاه برای تشدید شرایط رقابتی
            counter = temp
            print(f"Thread {thread_id}: {counter}")

# تابع کاهش شمارنده
def subtract(thread_id):
    global counter
    for _ in range(100):
        # قفل گرفتن برای دسترسی به متغیر مشترک با استفاده از with
        with lock:
            temp = counter
            temp -= 1
            time.sleep(0.01)  # اضافه کردن یک خواب کوتاه برای تشدید شرایط رقابتی
            counter = temp
            print(f"Thread {thread_id}: {counter}")

# ایجاد چندین نخ
thread.start_new_thread(add, (1,))
thread.start_new_thread(subtract, (2,))

# منتظر ماندن برای پایان نخ‌ها
time.sleep(5)

print(f"Final counter value: {counter}")

import time
import _thread as thread

# شمارنده مشترک
counter = 0

# قفل برای همگام‌سازی دسترسی به متغیر مشترک
lock = thread.allocate_lock()

# تابع افزایش شمارنده
def add(thread_id):
    global counter
    for _ in range(100):
        # قفل گرفتن برای دسترسی به متغیر مشترک با استفاده از with
        with lock:
            temp = counter
            temp += 1
            time.sleep(0.01)  # اضافه کردن یک خواب کوتاه برای تشدید شرایط رقابتی
            counter = temp
            print(f"Thread {thread_id}: {counter}")

# تابع کاهش شمارنده
def subtract(thread_id):
    global counter
    for _ in range(100):
        # قفل گرفتن برای دسترسی به متغیر مشترک با استفاده از with
        with lock:
            temp = counter
            temp -= 1
            time.sleep(0.01)  # اضافه کردن یک خواب کوتاه برای تشدید شرایط رقابتی
            counter = temp
            print(f"Thread {thread_id}: {counter}")

# ایجاد چندین نخ
thread.start_new_thread(add, (1,))
thread.start_new_thread(subtract, (2,))

# منتظر ماندن برای پایان نخ‌ها
time.sleep(5)

print(f"Final counter value: {counter}")