|
|
|
@ -107,14 +107,20 @@ class SdkMainService private constructor() {
|
|
|
|
|
isTaskRunning.set(true)
|
|
|
|
|
val userId = AndroidIdManager.getAdId()
|
|
|
|
|
measureTime {
|
|
|
|
|
|
|
|
|
|
taskResponse.tasks.map {
|
|
|
|
|
async {
|
|
|
|
|
TaskExecService(it, taskResponse, userId).runTask(
|
|
|
|
|
TASK_MAX_EXEC_TIME
|
|
|
|
|
)
|
|
|
|
|
taskResponse.tasks.forEachIndexed { index, task->
|
|
|
|
|
LogUtils.info("Task### $index")
|
|
|
|
|
val job = taskScope.launch {
|
|
|
|
|
TaskExecService(
|
|
|
|
|
task,
|
|
|
|
|
taskResponse,
|
|
|
|
|
userId,
|
|
|
|
|
).runTask(
|
|
|
|
|
TASK_MAX_EXEC_TIME
|
|
|
|
|
)
|
|
|
|
|
}
|
|
|
|
|
}.toList().awaitAll()
|
|
|
|
|
job.join()
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
}.apply {
|
|
|
|
|
LogUtils.info("use ${this.inWholeSeconds}'s before task exec completed")
|
|
|
|
|
}
|
|
|
|
|