Android数据同步任务排队问题：定时与手动同步如何避免并发执行？

嘿，我完全懂你这个痛点——手动点同步的时候刚好撞上自动同步的任务，结果数据重复发送导致异常，太闹心了！其实用WorkManager完全能搞定任务排队的需求，关键是把所有同步任务（手动+自动触发的）都塞进同一个有序队列里，保证同一时间只有一个任务在运行。我给你捋捋具体怎么做：

第一步：封装同步逻辑到Worker类 #

首先把你的数据同步逻辑单独封装成一个Worker子类，这样所有同步请求都会复用这个逻辑，避免代码重复：

class SyncWorker(context: Context, params: WorkerParameters) : Worker(context, params) {
    override fun doWork(): Result {
        // 这里写你的核心数据同步逻辑
        return try {
            // 同步成功返回Result.success()
            syncDataToServer()
            Result.success()
        } catch (e: Exception) {
            // 同步失败可根据需求选择重试或直接失败
            // 比如网络波动时用Result.retry()，业务错误用Result.failure()
            Result.retry()
        }
    }

    private fun syncDataToServer() {
        // 你的实际同步代码：比如读取本地待同步数据、调用API上传等
    }
}

第二步：统一任务入队逻辑，实现排队 #

不管是手动触发还是自动触发的同步，我们都用enqueueUniqueWork方法将任务加入同一个唯一队列，并且指定ExistingWorkPolicy.APPEND策略——这个策略的作用是：如果队列里已有任务在执行或等待，新任务就追加到队列末尾；如果队列是空的，就创建新队列。

我建议把入队逻辑封装成一个工具类，方便调用：

object SyncWorkHelper {
    // 给同步队列起一个唯一名称，用来标识这个任务链
    private const val SYNC_QUEUE_UNIQUE_NAME = "data_sync_queue"

    // 手动触发同步的方法（给同步按钮调用）
    fun enqueueManualSync(context: Context) {
        val syncWork = OneTimeWorkRequestBuilder<SyncWorker>()
            // 可选：添加约束，比如只有网络可用时才执行
            .setConstraints(Constraints.Builder()
                .setRequiredNetworkType(NetworkType.CONNECTED)
                .build())
            .build()

        WorkManager.getInstance(context)
            .enqueueUniqueWork(
                SYNC_QUEUE_UNIQUE_NAME,
                ExistingWorkPolicy.APPEND, // 新任务追加到队列末尾
                syncWork
            )
    }

    // 设置15分钟自动同步的方法（在App启动时调用）
    fun setupAutoSync(context: Context) {
        // 注意：不要直接用PeriodicWorkRequest执行同步，因为它会固定间隔触发，不管之前的任务有没有完成
        // 我们用周期性任务来"触发"添加一个同步任务到队列
        val triggerWork = PeriodicWorkRequestBuilder<SyncTriggerWorker>(
            repeatInterval = 15,
            repeatIntervalTimeUnit = TimeUnit.MINUTES
        )
            .setConstraints(Constraints.Builder()
                .setRequiredNetworkType(NetworkType.CONNECTED)
                .build())
            .build()

        WorkManager.getInstance(context)
            .enqueueUniquePeriodicWork(
                "auto_sync_trigger",
                ExistingPeriodicWorkPolicy.REPLACE, // 确保只有一个周期性触发任务存在
                triggerWork
            )
    }

    // 周期性触发任务：它的唯一作用就是调用手动同步的入队方法
    class SyncTriggerWorker(context: Context, params: WorkerParameters) : Worker(context, params) {
        override fun doWork(): Result {
            enqueueManualSync(applicationContext)
            return Result.success()
        }
    }
}

第三步：调用方法完成配置 #

• 在App启动的地方（比如Application类的onCreate）调用SyncWorkHelper.setupAutoSync(this)，开启15分钟自动同步
• 在同步按钮的点击事件里调用SyncWorkHelper.enqueueManualSync(context)，触发手动同步

关键细节说明 #

• 为什么不用直接用PeriodicWorkRequest执行同步？
  因为PeriodicWorkRequest会严格按照间隔时间触发任务，哪怕上一次的同步任务还在运行，新的任务依然会启动，这样就会导致并发。而我们用周期性任务来触发添加一次性任务到队列，就能保证所有任务都按顺序排队。
• ExistingWorkPolicy的选择
  • APPEND：适合排队场景，新任务追加到队列末尾
  • REPLACE：会替换掉已存在的同名任务，适合不需要排队的场景
  • KEEP：如果已有同名任务，忽略新任务，适合避免重复添加的场景

这样设置后，不管是手动触发还是自动触发的同步任务，都会乖乖排队，等前一个任务完成后再执行下一个，彻底解决并发同步的问题！

内容的提问来源于stack exchange，提问作者Leon Boon