Σίγουρα σου έχει τύχει: πρέπει να δουλέψεις με μια βιβλιοθήκη χρόνων που χρησιμοποιεί το κλασικό σύστημα callbacks και νιώθεις πως ο κώδικας μετατρέπεται σε χάος. Αυτή η δομή, όπου μια συνάρτηση καλεί μια άλλη και εκείνη με τη σειρά της μια τρίτη, καταλήγει να δημιουργεί το περίφημο «callback hell», κάνοντας τη συντήρηση του project εφιάλτη και την ανάγνωση της ροής δεδομένων να μοιάζει με αποκρυπτογράφηση ιερογλυφικών. Ευτυχώς, το Kotlin μας προσφέρει τις coroutines, οι οποίες βασικά είναι σαν νήματα αλλά πολύ πιο ελαφριά και αποδοτικά. Χάρη σε αυτές, μπορούμε να μετατρέψουμε εκείνες τις παλιές ασύγχρονες κλήσεις σε ένα στιλ ακολουθιακής προγραμματισμού, πετυχαίνοντας έναν κώδικα πολύ πιο καθαρό, ευανάγνωστο και, πάνω απ’ όλα, πιο εύκολο στο debugging χωρίς να μπλοκάρει το κύριο νήμα της εφαρμογής.
⚠️ Το ψηφιακό σας δακτυλικό αποτύπωμα (διεύθυνση IP) είναι εκτεθειμένο!
Η διεύθυνση IP σας είναι: ανίχνευση…
Κάντε streaming/download/«Σερφάρισμα» στο διαδίκτυο ανώνυμα με το Surfshark .
🌐 Μόνο $45.63 - 27 μήνες + Unlimited devicesΤο περιεχόμενο αυτού του σεναρίου δημιουργείται αυστηρά για εκπαιδευτικούς σκοπούς. Η χρήση γίνεται με δική σας ευθύνη.
Το πρόβλημα με τα callbacks και η άφιξη των coroutines έχει απασχολήσει κάθε Android προγραμματιστή που κληρονόμησε παλιό κώδικα. Όταν χρησιμοποιούμε APIs βασισμένα σε επανακλήσεις, η λογική θρυμματίζεται. Φαντάσου πως πρέπει να επικυρώσεις έναν χρήστη, μετά να ζητήσεις τους φίλους του και τέλος να του προτείνεις νέους· αν κάθε βήμα εξαρτάται από ένα callback, θα καταλήξεις με μια άπειρη εσοχή προς τα δεξιά. Επιπλέον, η διαχείριση σφαλμάτων σε κάθε επίπεδο αυτής της πυραμίδας είναι εξαντλητική και επιρρεπής σε λάθη. Εδώ μπαίνουν στο παιχνίδι οι συναρτήσεις αναστολής (suspend functions). Αυτές επιτρέπουν σε μια coroutine να σταματήσει σε ένα συγκεκριμένο σημείο και να επιστρέψει τον έλεγχο στο σύστημα μέχρι το αποτέλεσμα να είναι έτοιμο. Το καλύτερο απ’ όλα είναι πως, για όποιον διαβάζει τον κώδικα, μοιάζει σαν η λειτουργία να είναι σύγχρονη, αν και από κάτω το νήμα δεν είναι μπλοκαρισμένο και η εφαρμογή συνεχίζει να ανταποκρίνεται ομαλά.
Κατακτώντας το suspendCancellableCoroutine
Για να γεφυρώσουμε το χάσμα ανάμεσα στον κόσμο των callbacks και των coroutines, διαθέτουμε ένα θεμελιώδες εργαλείο που ονομάζεται suspendCancellableCoroutine. Αυτή η συνάρτηση λειτουργεί ως γέφυρα που μας παρέχει ένα αντικείμενο CancellableContinuation, το οποίο μας επιτρέπει να ξαναρχίσουμε την εκτέλεση της coroutine χειροκίνητα μόλις η παλιά API μας επιστρέψει το αναμενόμενο δεδομένο. Σε αντίθεση με την απλοποιημένη εκδοχή της, την suspendCoroutine, η cancellable παραλλαγή είναι η προτιμώμενη επιλογή στο επαγγελματικό development. Ο λόγος; Μας επιτρέπει να διαχειριστούμε την ακύρωση του Job. Αν ο χρήστης κλείσει την οθόνη ενώ το αίτημα βρίσκεται ακόμη σε εξέλιξη, μπορούμε να αποτρέψουμε την περιττή επανάληψη της coroutine, προλαμβάνοντας έτσι διαρροές μνήμης και σπατάλη πόρων.
Για να το υλοποιήσεις, απλώς τυλίγεις την ασύγχρονη κλήση και, μέσα στο callback επιτυχίας, καλείς το continuation.resume(resultado). Αν η λειτουργία αποτύχει, χρησιμοποιείς το continuation.resumeWithException(e) ώστε η εξαίρεση να ανέβει μέχρι το σημείο κλήσης και να μπορεί να πιαστεί με ένα συμβατικό μπλοκ try-catch, εξαλείφοντας την ανάγκη διαχείρισης σφαλμάτων σε πολλαπλά callbacks. Για μια βαθύτερη κατανόηση των σύγχρονων ροών δεδομένων στο Android, δες τον πλήρη οδηγό μας για το StateFlow και SharedFlow.
Προχωρημένη διαχείριση ακύρωσης και πόρων
Ένα από τα πιο κρίσιμα σημεία είναι να διασφαλίσουμε πως δεν αφήνουμε διεργασίες κρεμασμένες. Η μέθοδος invokeOnCancellation είναι ζωτική εδώ, αφού μας επιτρέπει να εγκαταστήσουμε έναν χειριστή που θα εκτελεστεί πάντα όταν η coroutine ακυρωθεί. Αυτό είναι θεμελιώδες αν η παλιά API απαιτεί να αποσυγγραφούμε χειροκίνητα έναν listener ή να κλείσουμε ένα αρχείο, ώστε να μην αφήσουμε σκουπίδια στο σύστημα. Πρέπει να κατανοήσεις πως η ακύρωση στο Kotlin είναι γενικά ασύγχρονη. Η εγγύηση άμεσης ακύρωσης διασφαλίζει πως, αν το Job ακυρώθηκε ενώ η συνάρτηση ήταν σε αναστολή, η coroutine δεν θα ξαναρχίσει επιτυχώς, ακόμη κι αν η μέθοδος επανάληψης είχε ήδη καλεστεί. Αυτό προστατεύει την ακεραιότητα της εφαρμογής, αποτρέποντας την εκτέλεση κώδικα σε στοιχεία UI που έχουν ήδη καταστραφεί.
Όταν ένα μόνο αποτέλεσμα δεν αρκεί: το callbackFlow
Υπάρχουν περιπτώσεις που δεν αναζητούμε μια μοναδική τιμή, αλλά μια συνεχή ροή δεδομένων, όπως οι ενημερώσεις τοποθεσίας GPS. Για αυτό, το suspendCancellableCoroutine υστερεί και πρέπει να καταφύγουμε στο callbackFlow. Αυτός ο κατασκευαστής μας επιτρέπει να εκπέμπουμε πολλαπλές τιμές μέσω μιας ασύγχρονης ροής βασισμένης σε κανάλια. Μέσα σε ένα callbackFlow, χρησιμοποιούμε τη συνάρτηση offer (ή trySend σε πρόσφατες εκδόσεις) για να στείλουμε δεδομένα στη ροή καθώς φτάνουν. Μια υποχρεωτική λεπτομέρεια είναι η κλήση awaitClose στο τέλος του μπλοκ· εκεί πρέπει να καθαρίσουμε τους πόρους και να αποσυγγραφούμε τα callbacks ώστε η ροή να μην μείνει αιωνίως ανοιχτή καταναλώνοντας μπαταρία και CPU. Για να εμβαθύνεις στο δηλωτικό UI στο Android, μελέτησε τον οδηγό μας για το Jetpack Compose.
Για να βελτιστοποιήσουμε αυτές τις ροές, μπορούμε να χρησιμοποιήσουμε τελεστές όπως το conflate(), ιδανικό όταν μας ενδιαφέρει μόνο η πιο πρόσφατη ενημέρωση και θέλουμε να αγνοήσουμε τις ενδιάμεσες τιμές αν ο συλλέκτης είναι πιο αργός από τον εκπομπό. Επιπλέον, η ενσωμάτωσή τους με asLiveData() επιτρέπει την παρακολούθηση από τη στιγμή που ο χρήστης ανοίγει την οθόνη έως όταν την κλείνει, διατηρώντας τη μνήμη υπό έλεγχο. Με αυτές τις τεχνικές, η γέφυρα ανάμεσα στο παρελθόν των callbacks και το μέλλον των coroutines γίνεται ασφαλής, καθαρή και χωρίς διαρροές.
