Message Passing এবং Synchronization

Message Passing এবং Synchronization

Message Passing এবং Synchronization হল Concurrent Programming এর দুটি গুরুত্বপূর্ণ কনসেপ্ট, যা একাধিক থ্রেড বা প্রোগ্রাম একসাথে কাজ করার সময় ডেটা আদান-প্রদান এবং কার্যক্রম সমন্বয় করতে সাহায্য করে। এই কনসেপ্টগুলি মাল্টি-থ্রেডিং বা ডিস্ট্রিবিউটেড সিস্টেমে অত্যন্ত গুরুত্বপূর্ণ, যেখানে বিভিন্ন থ্রেড বা প্রোগ্রাম একে অপরের সাথে সমন্বয় সাধন করে কাজ করে।

1. Message Passing

Message Passing হল একাধিক প্রসেস বা থ্রেডের মধ্যে ডেটা আদান-প্রদান করার একটি পদ্ধতি। এটি সাধারণত inter-process communication (IPC) এর একটি পদ্ধতি, যা দুটি আলাদা প্রসেস বা থ্রেডের মধ্যে তথ্য পাঠানোর এবং গ্রহণ করার জন্য ব্যবহৃত হয়। এই কৌশলটি ডিস্ট্রিবিউটেড সিস্টেম বা মাল্টি-থ্রেডিং সিস্টেমে ব্যবহার করা হয় যেখানে বিভিন্ন ইউনিট নিজেদের মধ্যে তথ্য শেয়ার করে কাজ করে।

Message Passing এর প্রক্রিয়া:

1. একটি প্রসেস বা থ্রেড অন্য একটি প্রসেস বা থ্রেডে বার্তা পাঠায়।
2. বার্তাটি একটি নির্দিষ্ট queue বা buffer তে সংরক্ষিত থাকে।
3. দ্বিতীয় প্রসেস বা থ্রেড সেই বার্তাটি গ্রহণ করে এবং প্রক্রিয়া করে।

Message Passing সিস্টেমে দুটি মূল কৌশল থাকে:

• Synchronous Message Passing: বার্তা পাঠানোর পর প্রেরক প্রসেস বা থ্রেডটি সঠিকভাবে বার্তার প্রাপ্তি না হওয়া পর্যন্ত অপেক্ষা করে।
• Asynchronous Message Passing: বার্তা পাঠানোর পর প্রেরক প্রসেস বা থ্রেডটি কোনো অপেক্ষা ছাড়াই কাজ চালিয়ে যায়।

উদাহরণ:

import std.stdio;
import core.thread;  // Thread library

void sender() {
    writeln("Sending message to receiver...");
    // Sending message using message passing concept
}

void receiver() {
    writeln("Receiving message...");
}

void main() {
    Thread senderThread = new Thread(&sender);
    Thread receiverThread = new Thread(&receiver);

    senderThread.start();
    receiverThread.start();

    senderThread.join();
    receiverThread.join();
}

এখানে:

• sender() এবং receiver() দুটি থ্রেড তৈরি করা হয়েছে, যেগুলি message passing এর মাধ্যমে একে অপরের সাথে যোগাযোগ করছে।

2. Synchronization

Synchronization হলো একাধিক থ্রেড বা প্রসেসের কার্যক্রম সমন্বয় করার প্রক্রিয়া, যাতে তারা সঠিকভাবে, নিরাপদে এবং নির্ভুলভাবে একে অপরের সাথে কাজ করতে পারে। এটি নিশ্চিত করে যে একাধিক থ্রেড একই রিসোর্স বা ডেটা স্ট্রাকচার ব্যবহার করার সময় কোনো রেস কন্ডিশন (race condition) বা ডেটা ত্রুটি না ঘটে।

Synchronization এর প্রয়োজনীয়তা:

• Race Condition: একাধিক থ্রেড যখন একসাথে একই রিসোর্স অ্যাক্সেস করে, তখন ডেটা ত্রুটি ঘটতে পারে। Synchronization এই সমস্যা প্রতিরোধ করতে সাহায্য করে।
• Critical Section: যখন একাধিক থ্রেড একটি নির্দিষ্ট অংশের কোড (critical section) একসাথে চালায়, তখন থ্রেডগুলিকে সমন্বিতভাবে কাজ করতে হয়, যাতে তারা একে অপরের কার্যক্রমে বাধা না দেয়।

Synchronization এর পদ্ধতি:

1. Mutex (Mutual Exclusion): এটি এমন একটি প্রযুক্তি, যা নিশ্চিত করে যে শুধুমাত্র একটি থ্রেড একে একে এক্সেস করতে পারে একটি রিসোর্স বা ক্রিটিক্যাল সেকশন।
2. Semaphore: এটি একটি নির্দিষ্ট সংখ্যক থ্রেডের মধ্যে রিসোর্সের অ্যাক্সেস সীমাবদ্ধ করতে ব্যবহৃত হয়।
3. Monitors: এটি থ্রেডের মধ্যে অটোমেটিক রিসোর্স সমন্বয় করতে ব্যবহৃত হয়।

উদাহরণ: Mutex ব্যবহার

import std.stdio;
import core.thread;  // Thread library
import core.sync;    // Synchronization library

shared static Mutex mtx;

void criticalSection(int id) {
    lock (mtx) {  // Mutex lock to prevent other threads from entering the critical section
        writeln("Thread ", id, " is in critical section.");
    }
}

void main() {
    Thread t1 = new Thread(() => criticalSection(1));
    Thread t2 = new Thread(() => criticalSection(2));

    t1.start();
    t2.start();

    t1.join();
    t2.join();
}

এখানে:

• Mutex ব্যবহার করা হয়েছে যাতে দুটি থ্রেড একে একে critical section এ প্রবেশ করতে পারে। এর মাধ্যমে একযোগভাবে একই রিসোর্স অ্যাক্সেস করার সময় রেস কন্ডিশন প্রতিরোধ করা হয়েছে।
• lock (mtx) দ্বারা একটি থ্রেড রিসোর্স অ্যাক্সেস করার আগে মিউটেক্স লক করা হয়েছে, যাতে অন্য থ্রেড সেই সময়ে ওই রিসোর্স ব্যবহার করতে না পারে।

3. Types of Synchronization

• Synchronous Synchronization: এতে থ্রেডগুলি একে একে কাজ করে এবং পরবর্তী থ্রেড পূর্ববর্তী থ্রেডের কাজ শেষ হওয়া পর্যন্ত অপেক্ষা করে।
• Asynchronous Synchronization: এতে থ্রেডগুলি একে একে কাজ না করে, বরং একে অপরকে একসাথে কাজ করতে দেয়, যাতে তারা নির্দিষ্ট শর্তে সমন্বিত হয়।

4. Advantages of Message Passing and Synchronization

Message Passing:

• Communication between Processes: এটি একাধিক প্রসেসের মধ্যে যোগাযোগ করার সহজ উপায়।
• Flexibility: সিস্টেমের মধ্যে প্রক্রিয়াগুলির মধ্যে তথ্য আদান-প্রদান স্বতন্ত্রভাবে করা যায়।

Synchronization:

• Data Integrity: একাধিক থ্রেড একই ডেটার উপর কাজ করার সময় ডেটা integrity বজায় রাখে।
• Avoid Race Conditions: থ্রেডগুলোর মধ্যে সঠিক সমন্বয়ের মাধ্যমে রেস কন্ডিশন প্রতিরোধ করা যায়।

সারসংক্ষেপ

• Message Passing: এটি একাধিক প্রসেস বা থ্রেডের মধ্যে ডেটা আদান-প্রদান করার একটি পদ্ধতি। এটি synchronous বা asynchronous হতে পারে এবং ডিস্ট্রিবিউটেড সিস্টেম বা মাল্টি-থ্রেডিং প্রোগ্রামে ব্যবহৃত হয়।
• Synchronization: এটি থ্রেডগুলির মধ্যে কার্যক্রম সমন্বয় করার একটি প্রক্রিয়া, যা ডেটার এক্সেস বা ক্রিটিক্যাল সেকশনে রেস কন্ডিশন এবং ডেটা ত্রুটি প্রতিরোধ করে। এর মধ্যে Mutex, Semaphore, এবং Monitors ব্যবহার করা হয়।

এই কনসেপ্টগুলো মাল্টি-থ্রেডিং বা ডিস্ট্রিবিউটেড সিস্টেমে অত্যন্ত গুরুত্বপূর্ণ, যেখানে একাধিক থ্রেড একে অপরের সাথে সমন্বয় করে কাজ করে।