1

我将文件（由用户选择）排入队列以上传，然后使用 WorkManager 更新同步状态，如下所示：

fun schedule(files: List<String>) {
    var cont = workManager
                .beginUniqueWork(issueId, APPEND, files.map { workRequest(it) })
                .then(updateSyncStatusWork)
                .enqueue()
}

它运作良好。但是当用户选择很多文件来查看日志时，我看到很多文件正在同时上传（大约 10 个甚至全部）。并且发生了很多超时。我相信减少并行上传次数会减少超时次数，但我在 WorkManager 或 WorkRequest 中找不到任何允许这样做的 API。

PS我不考虑将它们链接起来，因为上传失败会丢弃所有文件的上传。

4

1 回答 1

4

可以同时运行的作业数量实际上是由你配置的线程池决定的。默认值在此处Executor定义。

通常，当您使用Worker基类时，会将 的实例与Workerthis 上的线程相关联Executor。如果您想更好地控制与您Worker关联的线程，您可能需要查看CoroutineWorkeror ListenableWorker。

默认情况下的线程Executor数由设备上的内核数决定。如果您只想N同时运行作业，则必须执行以下操作：

  • 禁用默认WorkManager初始化程序（通过禁用内容提供者的清单合并）。

  • 在或您自己WorkManager的. 您需要在此处执行此操作，因为操作系统可以要求以前安排的 s 运行。有关更多信息，请查看此。Application.onCreate()ContentProviderWorker

val configuration = Configuration.Builder()
    // Defines a thread pool with 2 threads. 
    // This can be N (typically based on the number of cores on the device) 
    .setExecutor(Executors.newFixedThreadPool(2))
    .build()

WorkManager.initialize(context, configuration)

在上面的示例中，我正在创建一个具有 2 个线程的固定大小的线程池（这又可以同时处理 2 个线程Workers）。现在，当您将Workers 排入队列时，您将看到其中只有 2 个同时执行。

于 2020-02-19T18:21:07.520 回答