0
点赞
收藏
分享

微信扫一扫

Android Jetpack WorkManager 参数传递首先从启动任务的时候传递给Worker


首先从启动任务的时候传递给Worker

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 inputData = Data.Builder()
.putString("input_data", "jack")
.build()

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

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()}")
if (workInfo.state == WorkInfo.State.SUCCEEDED) {
val outputData=workInfo.outputData.getString("output_data")
Log.e(TAG, "outputData:${outputData}")
}

}

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

重点关注这两个地方

Android Jetpack WorkManager 参数传递首先从启动任务的时候传递给Worker_android jetpack

然后从Worker接受数据并返回数据

package com.anguomob.jecpack.work

import android.content.Context
import android.os.SystemClock
import android.util.Log
import androidx.work.Data
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);
val inputData = inputData.getString("input_data")

Log.d(TAG, "MyWork doWork: ${System.currentTimeMillis()}")
Log.d(TAG, "MyWork inputData: ${inputData}")
//任务执行完毕 将数据返回
val outputData = Data.Builder()
.putString("output_data", "执行成功")
.build()

return Result.success(outputData)
}
}

 

Android Jetpack WorkManager 参数传递首先从启动任务的时候传递给Worker_kotlin_02

 代码很少关注点也不必多说

然后执行

Android Jetpack WorkManager 参数传递首先从启动任务的时候传递给Worker_ide_03

 

举报

相关推荐

0 条评论