Войти Регистрация
Конкурентность

22. Синхронизация остатков, которую нельзя остановить

Сложная

Kotlin · 36 строк

Продавец нажимает «Синхронизировать остатки» — сервис проходит по его SKU, от 200 до 20 000, читает остаток из учётной системы и отправляет в маркетплейс. Кнопки «Стоп» и повторный запуск вызываются из разных потоков веб-сервера.

Отметьте строки с ошибками.

В работе: Интеграция складского учёта продавца с маркетплейсом.

Как проверяем Нажмите на строку с ошибкой и коротко напишите, что не так. Баг засчитан, если отмечена хотя бы одна его строка. Зачёт — найдено не меньше 60 % багов с учётом серьёзности (критичный весит 3, обычный 2, мелкий 1), а лишних отметок не больше, чем багов в коде. Пустые строки, скобки и комментарии лишними не считаем. Плюс 1 вопрос про поведение программы — на зачёт не влияют. Ответ один на подход: после него показываем разбор.
корутиныотменаCancellationExceptionThread.sleepMutex

Источник: на задачах Wildberries: остатки продавцов. Условие пересказано своими словами.

Давали на собеседовании? Ответов пока мало — ваш поможет.
  1. import kotlinx.coroutines.CoroutineScope
  2. import kotlinx.coroutines.Dispatchers
  3. import kotlinx.coroutines.Job
  4. import kotlinx.coroutines.launch
  6. class StockSync(
  7. private val api: MarketplaceApi,
  8. private val scope: CoroutineScope,
  9. ) {
  10. private var job: Job? = null
  12. // Продавец нажал «Синхронизировать остатки». Кнопку можно нажать повторно.
  13. fun start(skus: List<Long>) {
  14. job?.cancel()
  15. job = scope.launch(Dispatchers.IO) {
  16. for (sku in skus) {
  17. try {
  18. val qty = api.fetchStock(sku)
  19. api.pushStock(sku, qty)
  20. } catch (e: Exception) {
  21. println("sku $sku: ${e.message}")
  22. }
  23. Thread.sleep(50) // пауза между SKU, лимит API маркетплейса
  24. }
  25. }
  26. }
  28. fun stop() {
  29. job?.cancel()
  30. }
  31. }
  33. interface MarketplaceApi {
  34. suspend fun fetchStock(sku: Long): Int
  35. suspend fun pushStock(sku: Long, qty: Int)
  36. }