Как синхронизировать корутины в Android?

Для синхронизации корутин в Android можно использовать несколько подходов, в зависимости от конкретной задачи:

• Join: Ожидание завершения другой корутины.

  // Запускаем первую корутину
  val job1 = CoroutineScope(Dispatchers.Default).launch {
      delay(1000)
      println("Job 1 done")
  }
  
  // Запускаем вторую корутину
  val job2 = CoroutineScope(Dispatchers.Default).launch {
      delay(500)
      println("Job 2 done")
  }
  
  // Ожидаем завершения обеих корутин
  job1.join()
  job2.join()
  
  println("All jobs done")
  

• Await: Ожидание результата асинхронной операции, представленной Deferred.

  // Асинхронная операция, возвращающая результат
  val deferredResult = CoroutineScope(Dispatchers.Default).async {
      delay(1000)
      "Result from async"
  }
  
  // Ожидаем результат
  val result = deferredResult.await()
  println(result)
  

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

  suspend fun doParallelWork() {
      coroutineScope { // Создаем новую structured concurrency scope
          launch { delay(1000); println("Task 1 done") }
          launch { delay(500); println("Task 2 done") }
      } // Эта точка будет достигнута только после завершения task 1 и task 2
      println("All parallel tasks done")
  }
  

• Семантика акторов (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("Received $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 является рекомендуемым подходом по умолчанию для структурированной конкуренции.