Android中WorkManager主线程执行任务报错，求解决方案

我们使用的一款SDK要求相关调用必须在主线程执行。为实现一个通过WorkManager每日在后台运行的Worker，编写了如下代码：

@HiltWorker
class MyWorker @AssistedInject constructor(
    @Assisted context: Context,
    @Assisted workerParams: WorkerParameters,
    val mySdkRepo: MyRepository
): CoroutineWorker(context, workerParams) {
    override suspend fun doWork(): Result {
        withContext(Dispatchers.Main) {
            mySdkRepo.callFunc()
        }
        return Result.success()
    }
}

运行时触发如下错误：

java.lang.IllegalStateException: Event bus [Bus "default"] accessed from non-main thread null
at com.squareup.otto.ThreadEnforcer$2.enforce(ThreadEnforcer.java:47)
at com.squareup.otto.Bus.register(Bus.java:188)

尝试用runBlocking包裹主线程调用时，仅在应用处于前台时能正常运行，后台状态下依然无法满足SDK的主线程要求，求可行的解决思路。

• 明确根本原因
  WorkManager的后台Worker运行在独立的后台线程池中，当应用处于后台且进程被挂起时，主线程的Looper可能处于休眠状态，此时Dispatchers.Main无法提供有效的主线程执行上下文，导致SDK调用时触发线程检查错误。

• 方案1：手动绑定主线程Looper执行调用
  通过主线程Looper创建Handler，将SDK调用post到主线程执行，同时用CountDownLatch等待执行完成，避免Worker提前结束：

  override suspend fun doWork(): Result {
      return withContext(Dispatchers.IO) {
          val mainLooper = Looper.getMainLooper()
          // 检查主线程是否存活
          if (mainLooper.thread.isAlive) {
              val handler = Handler(mainLooper)
              val latch = CountDownLatch(1)
              var isSuccess = true
  
              handler.post {
                  try {
                      mySdkRepo.callFunc()
                  } catch (e: Exception) {
                      isSuccess = false
                      e.printStackTrace()
                  } finally {
                      latch.countDown()
                  }
              }
              // 设置超时时间，防止Worker无限阻塞
              latch.await(15, TimeUnit.SECONDS)
              if (isSuccess) Result.success() else Result.failure()
          } else {
              // 主线程已终止，无法执行SDK调用，返回失败或重试
              Result.retry()
          }
      }
  }
  

• 方案2：给Worker添加前台运行约束
  如果业务允许，可以让Worker仅在应用处于前台时运行，此时主线程必然处于活跃状态：

  // 创建Worker约束
  val constraints = Constraints.Builder()
      .setRequiresForeground(true) // 要求应用处于前台
      .build()
  
  // 构建周期性任务
  val dailyWorkRequest = PeriodicWorkRequestBuilder<MyWorker>(1, TimeUnit.DAYS)
      .setConstraints(constraints)
      .build()
  
  // 加入WorkManager队列
  WorkManager.getInstance(context).enqueueUniquePeriodicWork(
      "DailySdkTask",
      ExistingPeriodicWorkPolicy.REPLACE,
      dailyWorkRequest
  )
  

  缺点是无法实现纯后台自动执行的需求，依赖用户打开应用。

• 方案3：绕过SDK的主线程检查（谨慎使用）
  错误来自Otto Event Bus的线程校验，若SDK没有严格限制，可以通过反射修改Otto的ThreadEnforcer为允许任意线程：

  // 假设MyRepository内部持有Otto Bus实例，字段名为"bus"
  try {
      val busField = MyRepository::class.java.getDeclaredField("bus")
      busField.isAccessible = true
      val bus = busField.get(mySdkRepo) as Bus
  
      val enforcerField = Bus::class.java.getDeclaredField("enforcer")
      enforcerField.isAccessible = true
      enforcerField.set(bus, ThreadEnforcer.ANY)
  } catch (e: Exception) {
      e.printStackTrace()
  }
  
  // 之后再调用SDK方法
  mySdkRepo.callFunc()
  

  注意：这种方式可能违反SDK的使用条款，且可能导致SDK内部逻辑异常，必须经过充分测试后再使用。

内容的提问来源于stack exchange，提问作者Rowan Gontier