Πώς λειτουργεί το multithreading στη Java;

Question

Accepted Answer

**Το multithreading** επιτρέπει σε ένα πρόγραμμα Java να εκτελεί πολλαπλά threads ταυτόχρονα, ενεργοποιώντας παραλληλισμό (χρήση πολλαπλών πυρήνων CPU) και ευαισθησία (εκτέλεση εργασίας χωρίς αποκλεισμό). Η Java έχει υποστήριξη threads πρώτης κατηγορίας — αλλά η κοινή μεταβλητή κατάσταση εισάγει πολυπλοκότητα (race conditions) που πρέπει να διαχειρίζεται προσεκτικά. ## Δημιουργία threads ```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()` (δημιουργεί ένα νέο thread), όχι `run()` (η οποία απλώς εκτελεί τον κώδικα στο τρέχον thread συγχρόνως). ## Το βασικό πρόβλημα: race conditions ```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++` είναι στην πραγματικότητα τρεις λειτουργίες (ανάγνωση, αύξηση, εγγραφή). Όταν τα threads εναλλάσσονται, οι ενημερώσεις χάνονται — μια **race condition**. Αυτό είναι το κεντρικό πρόβλημα της συντρέχειας: κοινή μεταβλητή κατάσταση που προσπελαύνεται από πολλαπλά threads χωρίς συντονισμό. ## Λύσεις για ασφαλή κοινή κατάσταση ```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) ``` ## Συντονισμός thread ```java t.join(); // wait for thread t to finish Thread.sleep(1000); // pause the current thread // also: wait()/notify(), CountDownLatch, locks, etc. for coordination ``` ## Η σύγχρονη προσέγγιση: μην διαχειρίζεστε ακατέργαστα threads ```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 ``` ## Γιατί είναι σημαντικό Το multithreading ενεργοποιεί τα Java προγράμματα να χρησιμοποιούν πολλαπλούς πυρήνες και να παραμείνουν ευαίσθητα, αλλά είναι επίσης ένα από τα δυσκολότερα πεδία για να γίνει σωστά — **race conditions** από μη συγχρονισμένη κοινή μεταβλητή κατάσταση προκαλούν διαλείποντα, δύσκολα αναπαραγώγιμα σφάλματα. Η κατανόηση του τρόπου λειτουργίας των threads (`start()` vs `run()`), το κεντρικό πρόβλημα race-condition (γιατί το `count++` δεν είναι ασφαλές) και τα εργαλεία για τη διασφάλιση της ασφάλειας (`synchronized`, ατομικές κλάσεις, concurrent collections, immutability) είναι απαραίτητα για τη σύνταξη σωστού concurrent κώδικα. Οι σύγχρονες καλές πρακτικές ευνοούν αφαιρέσεις υψηλότερου επιπέδου (ExecutorService, CompletableFuture, virtual threads) έναντι της διαχείρισης ακατέργαστων threads. Αυτή είναι κριτική γνώση για server-side και high-performance Java, και ένα βαθύ, συχνά δοκιμασμένο θέμα που διαχωρίζει τους ικανούς από τους expert developers.