Как да синхронизираме корутините в Android?

За синхронизиране на корутините в Android можете да използвате няколко подхода в зависимост от конкретната задача:

• Join: Изчакване за завършване на друга корутина.

  // Стартираме първата корутина
  val job1 = CoroutineScope(Dispatchers.Default).launch {
      delay(1000)
      println("Работата 1 е завършена")
  }
  
  // Стартираме втората корутина
  val job2 = CoroutineScope(Dispatchers.Default).launch {
      delay(500)
      println("Работата 2 е завършена")
  }
  
  // Изчакваме и двете корутини да завършат
  job1.join()
  job2.join()
  
  println("Всички задачи са завършени")
  

• Await: Изчакване на резултата от асинхронна операция, представена чрез Deferred.

  // Асинхронна операция, връщаща резултат
  val deferredResult = CoroutineScope(Dispatchers.Default).async {
      delay(1000)
      "Резултат от async"
  }
  
  // Изчакване на резултата
  val result = deferredResult.await()
  println(result)
  

• CoroutineScope.coroutineScope: Създаване на нова област на видимост, която ще приключи само след като всички дъщерни корутини приключат. Полезно за структурирана конкуренция.

  suspend fun doParallelWork() {
      coroutineScope { // Създаваме нова структурирана конкуренция
          launch { delay(1000); println("Задача 1 е завършена") }
          launch { delay(500); println("Задача 2 е завършена") }
      } // Тази точка ще бъде достигната само след като задачите 1 и 2 приключат
      println("Всички паралелни задачи са завършени")
  }
  

• Семантика на актьорите (Channel): За обмен на съобщения и синхронизация на достъпа до променливи данни между корутините.

  // Създаваме канал за обмен на Int
  val channel = Channel<Int>()
  
  CoroutineScope(Dispatchers.Default).launch {
      // Изпращане на данни към канала
      for (i in 1..5) {
          channel.send(i)
      }
      channel.close() // Затваряме канала след изпращане
  }
  
  CoroutineScope(Dispatchers.Default).launch {
      // Получаване на данни от канала
      for (value in channel) {
          println("Получено $value")
      }
  }
  

• Mutex: За осигуряване на ексклузивен достъп до споделен ресурс.

  import kotlinx.coroutines.sync.Mutex
  import kotlinx.coroutines.sync.withLock
  
  val mutex = Mutex()
  var counter = 0
  
  suspend fun incrementCounter() {
      mutex.withLock { // Вземане на мютекса
          counter++
          // Мютексът ще бъде автоматично освободен при изход от блока
      }
  }
  

Изборът на метод зависи от това какво точно трябва да се синхронизира: изчакване за завършване, получаване на резултат, управление на паралелни задачи, обмен на данни или ексклузивен достъп. coroutineScope е препоръчителният подход по подразбиране за структурирана конкуренция.