Skip to content

Commit

Permalink
Add getAllConfigsAsync
Browse files Browse the repository at this point in the history
  • Loading branch information
KyuubiRan committed Feb 28, 2022
1 parent c9769a2 commit 5701501
Showing 1 changed file with 11 additions and 3 deletions.
14 changes: 11 additions & 3 deletions app/src/main/java/me/kyuubiran/qqcleaner/util/CleanManager.kt
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,7 @@ import java.io.File
import java.util.concurrent.LinkedBlockingQueue
import java.util.concurrent.ThreadPoolExecutor
import java.util.concurrent.TimeUnit
import kotlin.concurrent.thread

object CleanManager {
private val pool = ThreadPoolExecutor(1, 1, 5L, TimeUnit.MINUTES, LinkedBlockingQueue(256))
Expand Down Expand Up @@ -38,10 +39,10 @@ object CleanManager {

fun executeAll(showToast: Boolean = true) {
if (showToast) Log.toast(moduleRes.getString(R.string.clean_start))
getAllConfigs().let {
if (it.isEmpty()) {
getAllConfigsAsync {
if (it.isEmpty() || it.all { c -> !c.enable }) {
Log.toast(moduleRes.getString(R.string.no_config_enabled))
return@let
return@getAllConfigsAsync
}
it.forEach { data ->
execute(data, showToast)
Expand Down Expand Up @@ -76,6 +77,13 @@ object CleanManager {
return f
}

fun getAllConfigsAsync(onFinish: (Array<CleanData>) -> Unit) {
thread {
val arr = getAllConfigs()
onFinish(arr)
}
}

fun getAllConfigs(): Array<CleanData> {
val arr = ArrayList<CleanData>()
runCatching {
Expand Down

0 comments on commit 5701501

Please sign in to comment.