java Worker类怎么用?

Java中无内置Worker类,常见于Android Jetpack WorkManager;需继承CoroutineWorker等并实现doWork(),通过WorkManager提交OneTimeWorkRequest启动。

Java 中没有内置的 Worker 类,它不是 JDK 标准库的一部分。你看到的 Worker 很可能来自以下几种情况之一:Android 的 Worker(属于 androidx

.work 库)、某些第三方并发框架(如 Akka、Quasar),或者项目里自定义的类。最常见的是 Android Jetpack WorkManager 中的 Worker —— 下面按这个场景说明怎么用。

Android 中 Worker 用于后台任务调度

它专为可延迟、需保证执行的后台任务设计(比如上传日志、同步数据),系统会根据电池、网络等条件智能调度,即使 App 退出或设备重启后仍可能运行。

  • 必须继承 Worker 或其子类(如 CoroutineWorkerListenableWorker
  • 构造函数必须接收 ContextWorkerParameters
  • 核心逻辑写在 doWork() 方法里,返回 Result.success().failure().retry()

写一个基础 Worker 示例

(Kotlin 写法,Java 类似)

class UploadLogWorker(
    context: Context,
    params: WorkerParameters
) : CoroutineWorker(context, params) {
    override suspend fun doWork(): Result {
        return try {
            // 模拟上传日志
            uploadLogs()
            Result.success()
        } catch (e: Exception) {
            Result.failure()
        }
    }

    private suspend fun uploadLogs() {
        // 真实业务:调用 Retrofit、读取文件等
        delay(2000)
    }
}

如何启动这个 Worker

不能直接 new 或 run,要通过 WorkManager 提交:

  • 创建 OneTimeWorkRequestPeriodicWorkRequest
  • 可添加输入数据(setInputData())、约束(如仅在充电时运行)
  • WorkManager.getInstance().enqueue() 提交

例如:

val request = OneTimeWorkRequestBuilder()
    .setInputData(workDataOf("user_id" to "123"))
    .setConstraints(Constraints.Builder()
        .setRequiredNetworkType(NetworkType.CONNECTED)
        .build())
    .build()

WorkManager.getInstance(context).enqueue(request)

注意几个关键点

  • doWork() 运行在后台线程,默认超时 10 分钟,超时自动标记为 failed
  • 不能在 Worker 里操作 UI,也不建议做长时间阻塞操作(应拆成小任务或改用 ForegroundService
  • 如果需要与主线程交互(如更新通知),用 context.getSystemService(NotificationManager::class.java)
  • 调试时可用 adb shell cmd jobscheduler run -f 强制触发(需开启调试模式)

基本上就这些。如果你用的不是 Android 场景,比如是 Java 后端自己写的 Worker 类,那它就是普通业务类,用法完全由你定义 —— 关键看它的构造方式、是否实现 Runnable、有没有 start() 方法等。可以贴出类定义,我帮你分析怎么用。