Ποιες δυνατότητες παρέχει το Kotlin για εργασία με…

Το Kotlin παρέχει κορουτίνες (coroutines) για απλοποίηση των ασύγχρονων λειτουργιών, προσφέροντας ελαφριές ροές που δεν μπλοκάρουν το κύριο νήμα εκτέλεσης.

Βασικές δυνατότητες:

Λειτουργίες Αναστολής: Λειτουργίες με τη λέξη-κλειδί suspend, που μπορούν να ανασταλούν και να συνεχιστούν. Δεν μπλοκάρουν το νήμα που εκτελούνται.
```
suspend fun fetchData(): String {
    delay(1000) // Μιμείται μια μακρά λειτουργία
    return "Δεδομένα λήφθηκαν"
}
```
Κατασκευαστές κορουτίνων: Λειτουργίες που χρησιμοποιούνται για την εκκίνηση κορουτίνων:
- launch: Ξεκινά μια νέα κορουτίνα και επιστρέφει Job (χωρίς μπλοκάρισμα).
```
GlobalScope.launch {
    println("Η κορουτίνα ξεκίνησε")
}
```
- async: Ξεκινά μια νέα κορουτίνα και επιστρέφει Deferred<T> (μπλοκάρει κατά την κλήση .await()).
```
val deferred = GlobalScope.async {
    fetchData()
}
// ...
val result = deferred.await() // Περιμένει το αποτέλεσμα
```
- runBlocking: Μπλοκάρει το τρέχον νήμα μέχρι να ολοκληρωθεί η κορουτίνα (χρησιμοποιείται κυρίως για γέφυρες μεταξύ μπλοκαρισμένου και μη μπλοκαρισμένου κώδικα, π.χ. σε τεστ).
```
runBlocking {
    val data = fetchData()
    println(data)
}
```
CoroutineContext: Σύνολο στοιχείων που καθορίζουν τη συμπεριφορά της κορουτίνας, συμπεριλαμβανομένων των Dispatcher και Job.
- Dispatcher: Ορίζει το νήμα ή το σύνολο νημάτων όπου εκτελείται η κορουτίνα.
Dispatchers: Ενσωματωμένα αντικείμενα για διαχείριση νημάτων:
- Dispatchers.Default: Κοινό σύνολο φόντου νημάτων.
- Dispatchers.IO: Βελτιστοποιημένο για εισόδους/εξόδους (δίσκοι, δικτυακές λειτουργίες).
- Dispatchers.Main: Κύριο νήμα UI (για Android, JavaFX κ.ά.).
- Dispatchers.Unconfined: Ξεκινά την κορουτίνα στο τρέχον νήμα, αλλά μετά την αναστολή μπορεί να συνεχίσει σε οποιοδήποτε νήμα.
```
GlobalScope.launch(Dispatchers.IO) {
    // Εκτελείται στο νήμα εισόδου/εξόδου
}
```

Δομημένος Συγχρονισμός: Αρχή κατά την οποία οι κορουτίνες έχουν γονέα (CoroutineScope) και ακυρώνονται αυτόματα όταν ακυρωθεί ο γονέας. Αποτρέπει διαρροές πόρων και απλοποιεί τη διαχείριση κύκλου ζωής.

// Το CoroutineScope διαχειρίζεται αυτόματα τις θυγατρικές κορουτίνες
val scope = CoroutineScope(Dispatchers.Default)
val job = scope.launch {
    // ...
}
// Όταν ακυρωθεί το scope, ακυρώνονται και όλες οι θυγατρικές κορουτίνες
scope.cancel()

Channels: Κανάλια για ασφαλή μεταφορά δεδομένων μεταξύ κορουτίνων. Μπορούν να είναι:
- Unbuffered: Η λήψη γίνεται μόνο μετά την αποστολή.
- Buffered: Επιτρέπει την αποστολή πολλών στοιχείων πριν από το μπλοκάρισμα.
- Conflated: Διατηρεί μόνο το τελευταίο αποσταλμένο στοιχείο.
```
val channel = Channel<Int>()

scope.launch {
    for (x in 1..5) channel.send(x)
    channel.close()
}

scope.launch {
    for (y in channel) println(y)
}
```

Flow: Ροή δεδομένων που μπορεί να εκπέμπει πολλαπλές τιμές ασύγχρονα. Παρόμοιο με το RxJava Observable, αλλά πιο ελαφρύ και ενσωματωμένο με κορουτίνες.

fun simpleFlow(): Flow<Int> = flow {
    for (i in 1..3) {
        delay(100)
        emit(i) // Αποστολή τιμής
    }
}

runBlocking {
    simpleFlow().collect { value -> println(value) } // Κατανάλωση τιμών
}

Αυτές οι δυνατότητες επιτρέπουν τη συγγραφή ασύγχρονου κώδικα με επεξηγηματικό και εύκολα διαχειρίσιμο τρόπο, σε αντίθεση με τις αναδρομικές κλήσεις ή το Future.

Ποιες δυνατότητες παρέχει το Kotlin για εργασία με ασύγχρονες λειτουργίες;