Android Jetpack WorkManager 设置TAG,监听任务执行 取消任务

Posted 2022-05-25 安果移不动

 可以通过addTag的方式添加tag并通过

getWorkInfosByTagLiveData去监听任务。但是这里就不演示了 这里演示通过id的方法

首先work恢复到正常状态

package com.anguomob.jecpack.work

import android.content.Context
import android.os.SystemClock
import android.util.Log
import androidx.work.Worker
import androidx.work.WorkerParameters

class MyWork(val context: Context, val workerParameters: WorkerParameters) :
    Worker(context, workerParameters) 
    private val TAG = "MyWork"
    override fun doWork(): Result 
        SystemClock.sleep(2000);
        Log.d(TAG, "MyWork doWork: $System.currentTimeMillis()")
        return Result.success()
    

然后这个work 记住 是5s后才会被执行

package com.anguomob.jecpack.activity

import android.os.Build
import androidx.appcompat.app.AppCompatActivity
import android.os.Bundle
import android.util.Log
import android.view.View
import androidx.work.*
import com.anguomob.jecpack.R
import com.anguomob.jecpack.work.MyWork
import java.time.Duration
import java.util.*
import java.util.concurrent.TimeUnit

class WorkManagerActivity : AppCompatActivity() 
    private val TAG = "WorkManagerActivity"
    override fun onCreate(savedInstanceState: Bundle?) 
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_work_manager)
    

    fun addWork(view: View) 
        //触发条件
        val tempConstraints = Constraints.Builder()

//        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.M) 
//            tempConstraints //在待机状态下执行 需要api级别最低为23
//                .setRequiresDeviceIdle(true)
//        
        //不计费网络 如wifi
//        NetworkType.UNMETERED
        //非漫游
//        NetworkType.NOT_ROAMING
        //计费网络 如3g 4g
//        NetworkType.METERED
        //当网络连接上 可能要过几分钟才可以行
        //        .setRequiredNetworkType(NetworkType.CONNECTED)
        //对网络不强制要求 很快就可以执行
        val constraints = tempConstraints.setRequiredNetworkType(NetworkType.NOT_REQUIRED)
            //不在电量不足的执行
//            .setRequiresBatteryNotLow(true)
//            //在充电的时候执行
//            .setRequiresCharging(true)
//            //不在存储量不足的时候执行
//            .setRequiresStorageNotLow(true)
            .build()


        //配置任务
        // 一次性执行的任务
        val tempMyWork = OneTimeWorkRequest.Builder(MyWork::class.java)
            //设置触发条件
            .setConstraints(constraints)
            //设置延迟5s后执行
            .setInitialDelay(5, TimeUnit.SECONDS)

        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) 
            //线性增长 一开始2s 后面4s 8s 16s
            tempMyWork.setBackoffCriteria(BackoffPolicy.LINEAR, Duration.ofSeconds(2))
        
        //设置tag
        tempMyWork.addTag("WorkRequest1")

        val work = tempMyWork.build();

        //任务提交给WorkManager
        val workManager = WorkManager.getInstance(this);
        //将任务添加到队列当中
        workManager.enqueue(work)

        //观察任务
        workManager.getWorkInfoByIdLiveData(work.id).observe(this,  workInfo: WorkInfo ->
            Log.e(TAG, "addWork:$workInfo.toString()")

        )

        //2s后取消任务  任务会在5s后执行
        Timer().schedule(
            object : TimerTask() 
                override fun run() 
                    workManager.cancelWorkById(work.id)
                
            ,
            2000,
        )
    

setInitialDelay(5, TimeUnit.SECONDS)

在此之前我们通过2s的计时器给取消

     //2s后取消任务  任务会在5s后执行
        Timer().schedule(
            object : TimerTask() 
                override fun run() 
                    workManager.cancelWorkById(work.id)
                
            ,
            2000,
        )

监听执行的方法是这个

       //观察任务
        workManager.getWorkInfoByIdLiveData(work.id).observe(this,  workInfo: WorkInfo ->
            Log.e(TAG, "addWork:$workInfo.toString()")

        )

日志输出是这样

 先进入队列 然后再取消

如果不调用取消方法他会进入RUNING状态。更多细节可以自己测试。