如何保证新独特的工作将运行，无论已经运行的工作如何

Question

我想安排工作以将用户数据从我的应用程序同步到服务器。当用户将新信息保存在应用程序中时，该工作应运行。

fun scheduleWork(context: Context) {
    val constraints = Constraints.Builder()
        .setRequiredNetworkType(NetworkType.CONNECTED)
        .build()

    val request = OneTimeWorkRequest.Builder(ObservationSyncWorker::class.java)
        .setConstraints(constraints)
        .setExpedited(OutOfQuotaPolicy.RUN_AS_NON_EXPEDITED_WORK_REQUEST)
        .build()

    WorkManager
        .getInstance(context)
        .beginUniqueWork("syncData", ExistingWorkPolicy.APPEND_OR_REPLACE, request)
        .enqueue()
}

工作示例：

override suspend fun doWork(): Result {
  // get unsync'ed data from database
  val data = repository.getLocalData()
  // Start network request to sync data
  val response = repository.sync(data)
  if (response.isSuccessful) {
    // Network request complete, save server response
    repository.save(response.body())
  }

  // Done
  return Result.success()
}

在先前的数据完成之前，用户有机会保存新数据。文档工作策略有些限制，并希望确保我正在使用正确的策略。

工作人员：

public enum ExistingWorkPolicy {

    /**
     * If there is existing pending (uncompleted) work with the same unique name, cancel and delete
     * it.  Then, insert the newly-specified work.
     */
    REPLACE,

    /**
     * If there is existing pending (uncompleted) work with the same unique name, do nothing.
     * Otherwise, insert the newly-specified work.
     */
    KEEP,

    /**
     * If there is existing pending (uncompleted) work with the same unique name, append the
     * newly-specified work as a child of all the leaves of that work sequence.  Otherwise, insert
     * the newly-specified work as the start of a new sequence.
     * <br/>
     * <b>Note:</b> When using APPEND with failed or cancelled prerequisites, newly enqueued work
     * will also be marked as failed or cancelled respectively. Use
     * {@link ExistingWorkPolicy#APPEND_OR_REPLACE} to create a new chain of work.
     */
    APPEND,

    /**
     * If there is existing pending (uncompleted) work with the same unique name, append the
     * newly-specified work as the child of all the leaves of that work sequence. Otherwise, insert
     * the newly-specified work as the start of a new sequence.
     * <br/>
     * <b>Note:</b> If there are failed or cancelled prerequisites, these prerequisites are
     * <i>dropped</i> and the newly-specified work is the start of a new sequence.
     */
    APPEND_OR_REPLACE,
}

使用替换： 由于我同步数据的工作将捕获所有数据，因此我可以使用替换，这将取消第一个工作请求，并安排第二个工作请求。第二个工作请求应从取消的第一项工作中获取UNSYNC的数据。这里的好处可能是在离线时安排多个工作请求（请参阅在线约束），不会堆叠孩子以同步。

使用 keep ： 如果安排了现有的同步工作，这将无济于事。如果离线和用户多次保存数据，则此功能很好。数据的每一个保存都将导致未安排新的工作。但是，如果现有工作仍在流程或同步，则如果用户保存并计划了新工作，我认为新的工作请求将被忽略。对于我的用例来说，这似乎是一个不好的选择。

使用：附加： 如果以前的同步工作失败，则使用 Append 将导致未安排新的工作。 由于我希望将所有同步工作都安排，无论以前的工作如何，我认为这是一个糟糕的选择。

使用 append_or_replace ： 这是一个可行的选项，因为如果可以，则计划新作品的工作是可以的。此选项还将允许先前计划的工作完成，然后再安排更多工作。如果用户数据正在同步过程中并且保存新数据，则可以很好地工作。但是，在离线时保存多次会导致多个工作被附加。这将是浪费的，因为建立连接时，第一个工作请求将同步所有数据，而其余的工作任务无关紧要。

对于我的用例，我正在考虑替换或 append_or_replace 。

使用替换，由于可以取消工作，因此运行同步有可能在有效的服务器响应之间取消并将该响应保存到我的数据库之间。

使用 append_or_replace ，不会取消任何工作。但是，在某些情况下，额外的工作可能没有任何同步。我的工人确实检查了它是否有效，所以这可能是无害的。看来这是更安全的选择。

Answer 1

这不是一种干净的方法，但是您可以使用append_or_replace尝试这样的尝试：

fun shouldEnqueueNewWork(): Boolean {
        return getNumberOfUnfinishedWorks() < 2
    }

fun getNumberOfUnfinishedWorks(): Int {
    val workInfos = workManager.getWorkInfosForUniqueWork("syncData")
    var result = 0
    val workInfoList: List<WorkInfo> = workInfos.get()
    try {
        for (workInfo in workInfoList) {
            if (!workInfo.state.isFinished) {
                result++
            }
        }
    } catch (e: ExecutionException) {
        return result
    } catch (e: InterruptedException) {
        return result
    }
    return result
}

https://developer.android.com/topic/libraries/architecture/workmanager/workmanager/how-to/states-tace/states-and-bobservation#one-time time_work_states

https://developer.android.com/reference/androidx/work/workinfo.state#isfined（）“ rel =” nofollow noreferrer“> https://developer..android.com/reference.com/reference.com/reference/reference/androidx/androidx/androidx/work/work/workinfo.state.state #IsFined（）