ইন্টার-প্রসেস কমিউনিকেশন (IPC)

# সম্পূর্ণ ইন-মেমরি সিমুলেশন -- বাস্তব থ্রেড/প্রসেস বা OS shared-memory কল নয়

shared = {"counter": 0}

def read_counter(mem):
    return mem["counter"]

def write_counter(mem, value):
    mem["counter"] = value

print("--- Shared memory: দুটি প্রসেস কোনো কোঅর্ডিনেশন ছাড়াই counter += 1 করতে চায় ---")
# increment আসলে ৩টি সাব-স্টেপ: read -> add -> write। এখানে ম্যানুয়ালি ইন্টারলিভ করা হলো:
val_a = read_counter(shared)        # প্রসেস A পড়লো
val_b = read_counter(shared)        # প্রসেস B পড়লো (A এখনো লিখেনি!)
print(f"A পড়লো: {val_a}  |  B পড়লো: {val_b} (দুজনেই একই পুরনো মান পেলো)")
val_a += 1                          # A হিসাব করলো
val_b += 1                          # B হিসাব করলো
write_counter(shared, val_a)        # A লিখলো
print(f"A লিখলো: {val_a}  ->  counter = {shared['counter']}")
write_counter(shared, val_b)        # B লিখলো -- A-এর আপডেট মুছে গেলো!
print(f"B লিখলো: {val_b}  ->  counter = {shared['counter']}  (A-এর আপডেট হারিয়ে গেলো!)")

print("\nপ্রত্যাশিত মোট (দুইবার +1) =", 2)
print("প্রকৃত counter =", shared["counter"])
print("রেস কন্ডিশনের কারণে একটি আপডেট হারিয়ে গেলো?", shared["counter"] < 2)

print("\n--- Message passing: deque-ভিত্তিক মেইলবক্স দিয়ে send()/receive() ---")
from collections import deque
mailbox = deque()

def send(mb, msg):
    mb.append(msg)
    print(f"send(): '{msg}' পাঠানো হলো, মেইলবক্সে এখন {len(mb)}টি বার্তা")

def receive(mb):
    if not mb:
        print("receive(): মেইলবক্স খালি, কিছু নেই")
        return None
    msg = mb.popleft()
    print(f"receive(): '{msg}' গ্রহণ করা হলো, মেইলবক্সে এখন {len(mb)}টি বার্তা বাকি")
    return msg

send(mailbox, "প্রসেস A থেকে: হ্যালো")
send(mailbox, "প্রসেস A থেকে: ডেটা রেডি")
receive(mailbox)
receive(mailbox)
receive(mailbox)

print("\n--- তুলনা ---")
print("Shared memory: দ্রুত, কিন্তু M5 (সিনক্রোনাইজেশন) ছাড়া উপরের মতো race condition ঘটে")
print("Message passing: প্রতি বার্তায় OS জড়িত থাকায় ধীর, কিন্তু কোনো shared state নেই বলেই নিরাপদ")