Java-তে মাল্টিথ্রেডিং কীভাবে কাজ করে?

Question

Accepted Answer

**মাল্টিথ্রেডিং** একটি Java প্রোগ্রামকে একাধিক থ্রেড একযোগে চালাতে দেয়, যা সমান্তরালতা (একাধিক CPU কোর ব্যবহার) এবং প্রতিক্রিয়াশীলতা (কাজ ব্লক না করে করা) সক্ষম করে। Java-তে প্রথম-শ্রেণীর থ্রেড সমর্থন আছে — কিন্তু ভাগ করা পরিবর্তনশীল অবস্থা জটিলতা চালু করে (রেস অবস্থা) যা সাবধানে পরিচালনা করতে হবে। ## থ্রেড তৈরি করা ```java // 1. Implement Runnable (preferred — separates task from thread) Runnable task = () -> System.out.println("running on " + Thread.currentThread().getName()); Thread t = new Thread(task); t.start(); // start() runs it on a NEW thread (run() would run on the CURRENT thread!) // 2. modern: use an ExecutorService instead of raw threads ExecutorService executor = Executors.newFixedThreadPool(4); executor.submit(task); ``` **মূল সাবধানী বিষয়:** `start()` কল করুন (একটি নতুন থ্রেড তৈরি করে), `run()` নয় (যা শুধু বর্তমান থ্রেডে কোড সিঙ্ক্রোনাসভাবে চালায়)। ## মূল সমস্যা: রেস অবস্থা ```java // ❌ multiple threads modifying shared state → unpredictable results class Counter { int count = 0; void increment() { count++; } // NOT atomic: read → add → write (can interleave) } // 1000 threads each incrementing 1000 times → final count is often < 1,000,000! ``` `count++` আসলে তিনটি অপারেশন (পড়া, বৃদ্ধি, লেখা)। যখন থ্রেডগুলি আন্তর্ভুক্ত করে, আপডেটগুলি হারিয়ে যায় — একটি **রেস অবস্থা**। এটি সমন্বয়ের কেন্দ্রীয় চ্যালেঞ্জ: একাধিক থ্রেড দ্বারা সমন্বয় ছাড়াই অ্যাক্সেস করা ভাগ করা পরিবর্তনশীল অবস্থা। ## নিরাপদ ভাগ করা অবস্থার সমাধান ```java // 1. synchronized — only one thread in the method/block at a time (a lock) synchronized void increment() { count++; } // 2. atomic classes — lock-free atomic operations AtomicInteger count = new AtomicInteger(0); count.incrementAndGet(); // atomic, thread-safe, efficient // 3. concurrent collections — built for multi-threaded access ConcurrentHashMap map = new ConcurrentHashMap<>(); // 4. immutability — immutable objects are inherently thread-safe (nothing to corrupt) ``` ## থ্রেড সমন্বয় ```java t.join(); // wait for thread t to finish Thread.sleep(1000); // pause the current thread // also: wait()/notify(), CountDownLatch, locks, etc. for coordination ``` ## আধুনিক পদ্ধতি: কাঁচা থ্রেড পরিচালনা করবেন না ```text ✓ Use ExecutorService / thread pools (not new Thread() per task — expensive) ✓ Use CompletableFuture for async composition ✓ Use concurrent collections and atomic classes over manual synchronization ✓ Java 21+ adds Virtual Threads — millions of lightweight threads for I/O concurrency ``` ## কেন এটি গুরুত্বপূর্ণ মাল্টিথ্রেডিং Java প্রোগ্রামগুলিকে একাধিক কোর ব্যবহার করতে এবং প্রতিক্রিয়াশীল থাকতে সক্ষম করে, কিন্তু এটি সঠিক করার জন্য সবচেয়ে কঠিন ক্ষেত্রগুলির মধ্যে একটি — অসঙ্গত ভাগ করা পরিবর্তনশীল অবস্থা থেকে **রেস অবস্থা** আন্তঃ-বিস্তৃত, পুনরুৎপাদন করা কঠিন বাগ সৃষ্টি করে। থ্রেডগুলি কীভাবে কাজ করে তা বোঝা (`start()` বনাম `run()`)، মূল রেস-অবস্থা সমস্যা (কেন `count++` নিরাপদ নয়), এবং সুরক্ষা নিশ্চিত করার জন্য সরঞ্জাম (`synchronized`, পরমাণু শ্রেণী, সমসাময়িক সংগ্রহ, অপরিবর্তনীয়তা) সঠিক সমসাময়িক কোড লেখার জন্য প্রয়োজনীয়। আধুনিক সেরা অনুশীলন কাঁচা থ্রেড ব্যবস্থাপনার উপর উচ্চ-স্তরের বিবর্তন (ExecutorService, CompletableFuture, ভার্চুয়াল থ্রেড) পছন্দ করে। এটি সার্ভার-পাশ এবং উচ্চ-পারফরম্যান্স Java জন্য গুরুত্বপূর্ণ জ্ঞান, এবং একটি গভীর, ঘন ঘন-পরীক্ষিত বিষয় যা সক্ষম থেকে বিশেষজ্ঞ ডেভেলপারদের আলাদা করে।