This is an old revision of the document!
====== Συγχρονισμός Νημάτων ====== Ο συγχρονισμός νημάτων έχει σαν στόχο να επιτρέπει σε διαφορετικά νήματα να διαβάζουν ή να γράφουν με ασφάλεια σε διαμοιραζόμενες μεταβλητές χωρίς να προκύπτουν ασάφειες ως προς τις τιμές των μεταβλητών αυτών λόγω ταυτόχρονης μεταβολής τους. Ας υποθέσουμε ότι έχουμε δύο νήματα Α, Β και το νήμα Α θέλει να ειδοποιήσει το νήμα Β μόλις ολοκληρώσει την επεξεργασία των δεδομένων του, ώστε εκείνο να ξεκινήσει την επεξεργασία των δεδομένων. ===== Συγχρονισμός μέσω διαμοιραζόμενων αντικειμένων και διαρκούς επανάληψης ===== Ο πιο απλός τρόπος για να επικοινωνήσουν δύο νήματα μεταξύ τους είναι μέσω διαμοιραζόμενων αντικειμένων. Για το παραπάνω παράδειγμα, ας υποθέσουμε ότι το νήμα Α θέτει την boolean τιμή //hasDataToProcess// σε true μέσα από μία συγχρονισμένη μέθοδο και το νήμα Β διαβάζει την τιμή //hasDataToProcess// και πάλι μέσω μίας συγχρονισμένης μεθόδου <code java MySignal.java> public class MySignal{ protected boolean hasDataToProcess = false; public synchronized boolean hasDataToProcess(){ return this.hasDataToProcess; } public synchronized void setHasDataToProcess(boolean hasData){ this.hasDataToProcess = hasData; } } </code> Η παραπάνω κλάση μπορεί να χρησιμοποιηθεί για την επικοινωνία μεταξύ δύο νημάτων Α, Β. Ας υποθέσουμε ότι το νήμα **Β** περιμένει έως ότου τα δεδομένα να είναι διαθέσιμα από το νήμα **Α**, περιμένοντας διαρκώς σε ένα while() βρόγχο (loop), όπως παρακάτω <code java BusyWait.java> public class BusyWait implements Runnable { protected MySignal signal; BusyWait(MySignal s) { signal = s; } public static void main(String args[]) { MySignal sharedSignal = new MySignal(); new Thread(new BusyWait(sharedSignal)).start(); new Thread(new BusyWait(sharedSignal)).start(); } public void run() { } } </code> Στο παράδειγμα αυτό το νήμα περιμένει, αλλά παράλληλα παραμένει και ενεργό (busy). ===== Συγχρονισμός με χρήση wait(), notify(), notifyAll() ===== Το παραπάνω σχήμα αν και είναι αποτελεσματικό ως προς τον συγχρονισμό δαπανά πολλά resources καθώς το νήμα Β παραμένει ενεργό περιμένοντας. Θα ήταν πιο αποδοτικό αν αντί να παραμένει ενεργό το νήμα Β //"κοιμόταν"// περιμένοντας το νήμα Α να ολοκληρώσει. Η Java διαθέτει ένα μηχανισμό προκειμένου να επιτρέψει σε νήματα να κοιμηθούν περιμένοντας τα νήματα που εκτελούνται να ολοκληρώσουν το έργο τους. Συγκεκριμένα διαθέτει τρεις μεθόδους που επιτρέπουν το συγκεκριμένο συγχρονισμό [[https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#wait--|wait()]], [[https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#notify--|notify()]], [[https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html#notifyAll--|notifyAll()]]. Όταν ένα νήμα καλεί την μέθοδο //wait()// πάνω σε ένα αντικείμενο, τότε το νήμα κοιμάται έως ότου ένα άλλο νήμα καλέσει τη μέθοδο //notify()// πάνω στο ίδιο αντικείμενο. Τότε το νήμα που κοιμόταν ξυπνάει και συνεχίζει την εκτέλεση του. Προκειμένου να κληθούν οι //wait()// και //notify()// __το νήμα που τις καλεί θα πρέπει να λάβει το monitor lock για το συγκεκριμένο αντικείμενο__, δηλαδή τόσο η //wait()// όσο και η //notify()// __θα πρέπει να κληθούν μέσα σε μία συγχρονισμένη μέθοδο ή συγχρονισμένο μπλοκ__. Δείτε το παρακάτω παράδειγμα συγχρονισμού με χρήση των //wait()/notify()//. <code java MonitorObject.java> public class MonitorObject{ } </code> <code java MyWaitNotify.java> public class MyWaitNotify{ MonitorObject myMonitorObject = new MonitorObject(); public void doWait(){ synchronized(myMonitorObject){ try{ myMonitorObject.wait(); } catch(InterruptedException e){...} } } public void doNotify(){ synchronized(myMonitorObject){ myMonitorObject.notify(); } } } </code> Η μέθοδος //notify()// ξυπνάει ένα νήμα που περιμένει στο συγκεκριμένο //monitor lock//. Όπως βλέπετε οι μέθοδοι //wait()// και //notify()// καλούνται μέσα σε ένα συγχρονισμένο block του οποίου το //monitor lock// αφορά το αντικείμενο από το οποίο καλούνται οι //wait()// και //notify()//. Το παραπάνω σχήμα είναι υποχρεωτικό, δηλαδή - οι //wait()// και //notify()// θα πρέπει να κληθούν μέσα σε ένα συγχρονισμένο block ή μία συγχρονισμένη μέθοδο. Αν δεν γίνει αυτό τότε λαμβάνουμε ένα [[http://docs.oracle.com/javase/7/docs/api/java/lang/IllegalMonitorStateException.html|IllegalMonitorStateException]]. - δεν μπορούμε να αποκτήσουμε το monitor lock ενός διαφορετικού αντικειμένου από αυτό με το οποίο καλούμε τις wait()/notify(). Επίσης, βλέπετε ότι οι //wait()// και //notify()// βρίσκονται μέσα σε ένα block. Επίσης, εκτός της //notify()// υπάρχει και η //notifyAll()// που ξυπνάει όλα τα νήματα που περιμένουν στο συγκεκριμένο //monitor lock// σε αντίθεση με την notify() που ξυπνάει μόνο ένα νήμα. Όταν περισσότερα του ενός νήματα περιμένουν το ποιο νήμα θα ξυπνήσει η //notify()// δεν ελέγχεται από εσάς. Πως όμως το παραπάνω σχήμα είναι δυνατόν; Το thread που περιμένει δεν κρατά το monitor lock που έχει λάβει για το αντικείμενο myMonitorObject, όσο αυτό παραμένει μέσα στο synchronized block; Η απάντηση είναι αρνητική. Όσο το νήμα περιμένει ελευθερώνει το συγκεκριμένο monitor lock. Το παραπάνω επιτρέπει σε άλλες μεθόδους που δεν έχουν το lock να λάβουν το lock μπαίνοντας σε ένα συγχρονισμένο block ή συγχρονισμένη συνάρτηση και να καλέσουν τις //wait()// και //notify()// μέσα από εκεί. Όταν ένα νήμα ξυπνήσει δεν μπορεί αμέσως να βγει από την μέθοδο //wait()//. Αντίθετα θα πρέπει να περιμένει μέχρι το νήμα που κάλεσε την //notify()// να βγει από το συγχρονισμένο block ή την συγχρονισμένη μέθοδο. Αυτό συμβαίνει διότι το νήμα που ξυπνάει θα πρέπει να λάβει το //lock// του αντικειμένου από το οποίο κλήθηκε η μέθοδος //wait()// καθώς αυτή καλείτε πάντα μέσα σε ένα συγχρονισμένο block ή μία συγχρονισμένη μέθοδο. Σε αναλογία, αν πολλαπλά νήματα ξυπνήσουν μέσα από μία κλήση της //notifyAll()//, τότε αυτά τα νήματα δεν μπορούν να ξυπνήσουν όλα μαζί, αλλά ένα-ένα καθώς κάθε ένα νήμα που ξυπνάει θα πρέπει να λάβει το lock πάνω στο οποίο περιμένει πριν συνεχίσει την εκτέλεση του. ===== Χαμένα σήματα συγχρονισμού ===== Στο παραπάνω παράδειγμα η μέθοδος //doWait()// δεν ελέγχει εάν έχει έρθει ένα σήμα ή όχι πριν πάει για ύπνο το νήμα που την καλεί. Αν ένα σήμα έρθει πριν εκείνη κοιμηθεί δεν έχει τρόπο να ελέγξει αν το σήμα έφτασε ή όχι. Για τον λόγο αυτό χρησιμοποιούμε μία επιπλέον boolean μεταβλητή που κρατά την πληροφορία κατά πόσο δημιουργήθηκε ένα σήμα ή όχι. Ο παραπάνω κώδικας αναμορφώνεται ως εξής: <code java MyWaitNotify2.java> public class MyWaitNotify2{ MonitorObject myMonitorObject = new MonitorObject(); boolean wasSignalled = false; public void doWait(){ synchronized(myMonitorObject){ if(!wasSignalled){ try{ myMonitorObject.wait(); } catch(InterruptedException e){...} } //clear signal and continue running. wasSignalled = false; } } public void doNotify(){ synchronized(myMonitorObject){ wasSignalled = true; myMonitorObject.notify(); } } } </code> ===== Ξαφνικά ξυπνήματα (Spurious wake-ups) ===== Υπάρχει η πιθανότητα ένα νήμα να ξυπνήσε ακόμη και δίχως να κληθεί η //notify()// ή η //notifyAll()//. Σε αυτή την περίπτωση αν το νήμα λάβει το lock θα ξυπνήσει και θα συνεχίσει την εκτέλεση του δίχως να εξετάσει αν έχει έρθει ένα σήμα ή όχι. Για το λόγο αυτό, καλό θα είναι ο έλεγχος που γίνεται παραπάνω (μέσα στην //if()//) να αντικατασταθεί με ένα while() loop ώστε να είμαστε σίγουροι ότι όσο δεν έχει έρθει κάποιο σήμα το νήμα που περιμένει δεν θα συνεχίσει την εκτέλεση του. Δείτε τον τελικό κώδικα παρακάτω <code java MyWaitNotify3.java> public class MyWaitNotify3{ MonitorObject myMonitorObject = new MonitorObject(); boolean wasSignalled = false; public void doWait(){ synchronized(myMonitorObject){ while(!wasSignalled){ try{ myMonitorObject.wait(); } catch(InterruptedException e){...} } //clear signal and continue running. wasSignalled = false; } } public void doNotify(){ synchronized(myMonitorObject){ wasSignalled = true; myMonitorObject.notify(); } } } </code> Το παραπάνω σχήμα δουλεύει επίσης πολύ καλά εάν πολλαπλά νήματα περιμένουν σε ένα monitor lock. Αν τα νήματα αυτά ξυπνούν μέσα από μία κλήση της μεθόδου //notifyAll()//, τότε μέσα από τον παραπάνω κώδικα μόνο ένα από τα νήματα θα λάβει το monitor lock (το πρώτο που ξύπνησε και έλαβε το lock του αντικειμένου myMonitorObject). Τα υπόλοιπα, όταν με την σειρά τους θα λάβουν το lock, θα ελέγξουν την τιμή της μεταβλητής //wasSignalled// και θα πάνε πάλι για ύπνο εφόσον την βρουν ίση με //false//.
