মিউটেক্স লক ও সেমাফোর

class Semaphore:
    def __init__(self, initial_value):
        self.value = initial_value
        self.waiting = []  # ব্লকড প্রসেসের নামের তালিকা (FIFO)

    def wait(self, name):  # P operation
        self.value -= 1
        if self.value < 0:
            self.waiting.append(name)
            print(f"  {name}: wait() -> value={self.value} (BLOCKED, waiting={self.waiting})")
            return False  # ব্লকড হয়ে গেল
        print(f"  {name}: wait() -> value={self.value} (ক্রিটিক্যাল সেকশনে প্রবেশ)")
        return True  # সরাসরি এগিয়ে গেল

    def signal(self, name):  # V operation
        self.value += 1
        if self.value <= 0 and self.waiting:
            woken = self.waiting.pop(0)
            print(f"  {name}: signal() -> value={self.value} (জাগ্রত করা হলো: {woken})")
            return woken
        print(f"  {name}: signal() -> value={self.value} (কেউ অপেক্ষমাণ নেই)")
        return None


print("== Demo ১: বাইনারি সেমাফোর -- value ও waiting list ট্র্যাক করা ==")
demo = Semaphore(1)
demo.wait("A")       # value 1 -> 0, সরাসরি প্রবেশ
demo.wait("B")       # value 0 -> -1, ব্লকড
demo.signal("A")     # value -1 -> 0, B জাগে
print()

print("== Demo ২: L17-এর shared_counter, এবার mutex দিয়ে প্রোটেক্টেড ==")
mutex = Semaphore(1)
shared_counter = 0

def protected_increment(name):
    global shared_counter
    mutex.wait(name)
    # ক্রিটিক্যাল সেকশন -- strictly sequential acquire-modify-release, তাই কোনো ইন্টারলিভিং সম্ভব নয়
    current = shared_counter
    current += 1
    shared_counter = current
    print(f"  {name}: increment সম্পন্ন -> shared_counter={shared_counter}")
    mutex.signal(name)

for name in ["P1", "P2", "P1", "P2"]:  # আগের মতোই মোট ৪টি increment-এর চেষ্টা
    protected_increment(name)

expected = 4
print()
print("ফাইনাল shared_counter =", shared_counter)
print("প্রত্যাশিত =", expected)
print("মিলেছে -- এবার আর কোনো লস্ট আপডেট নেই!" if shared_counter == expected else "মিলেনি!")