如何在无并发场景下异步运行Kotlin任务，实现Android图片按序上传S3

核心实现思路 #

使用线程安全的阻塞队列存储待上传的图片任务，配合单工作线程消费队列，保证同一时间仅存在一个运行中的上传任务，从根源避免并发上传问题。

具体实现步骤 #

• 首先在Service内部定义上传任务实体与阻塞队列
  定义UploadTask数据类存储图片本地路径、文件名、上传状态回调等必要参数，初始化LinkedBlockingQueue<UploadTask>作为任务队列，该队列默认线程安全，无需额外加锁即可支持多线程写入任务。
• 启动单工作线程消费队列
  Service创建时启动独立的后台工作线程，死循环从队列中取任务：队列为空时take()方法会自动阻塞挂起，不会空转消耗系统资源；拿到任务后同步执行S3上传逻辑，当前任务处理完成（无论成功/失败）后再取下一个任务，自然实现逐个上传的要求。
  参考代码：

  // Service onCreate方法中初始化
  private val uploadQueue = LinkedBlockingQueue<UploadTask>()
  private val uploadWorker = Thread {
      while (!isInterrupted) {
          try {
              val currentTask = uploadQueue.take()
              // 调用S3同步上传方法，不要用异步回调接口，避免线程不等执行结果就取下一个任务
              executeS3SyncUpload(currentTask)
          } catch (e: InterruptedException) {
              // 线程被中断时退出循环，对应Service销毁逻辑
              break
          }
      }
  }.apply { start() }
  

• 对外暴露添加上传任务的方法
  给Service编写公开的addUploadTask方法，相机Activity拍摄完成后，仅需要把图片参数封装为UploadTask实例调用该方法塞入队列即可，无需感知上传执行时机，实现拍照逻辑和上传逻辑的完全解耦。
  参考代码：

  fun addUploadTask(task: UploadTask) {
      uploadQueue.offer(task)
      // 可在此处更新前台Service的通知，展示当前待上传的任务数量
  }
  

• 异常与状态留存处理
  上传失败时可根据业务需求在上传逻辑中增加重试机制，到达重试上限后再标记为上传失败；如果应用重启，可优先扫描本地待上传图片目录，把未完成的上传任务先塞回队列再启动消费线程，避免任务丢失。

注意事项 #

• 按照你的Android适配目标版本，提前申请FOREGROUND_SERVICE、FOREGROUND_SERVICE_DATA_SYNC等前台服务对应权限，正确配置通知通道。
• S3上传优先使用官方SDK的同步上传接口，如果用异步回调接口，需要加锁等回调完成后再释放，避免消费线程提前取下一个任务。
• Service销毁时主动调用uploadWorker.interrupt()中断工作线程，避免内存泄漏。

内容的提问来源于stack exchange，提问作者Sanket Bhangale