From f48b5b71a70168ca30d0b74848723d6e679681e0 Mon Sep 17 00:00:00 2001 From: fankesyooni Date: Wed, 14 Sep 2022 22:58:01 +0800 Subject: [PATCH] Modify remove parallelForEach function because it is no need anymore in UtilsFactory --- .../yukihookapi/hook/utils/UtilsFactory.kt | 17 ----------------- 1 file changed, 17 deletions(-) diff --git a/yukihookapi/src/api/kotlin/com/highcapable/yukihookapi/hook/utils/UtilsFactory.kt b/yukihookapi/src/api/kotlin/com/highcapable/yukihookapi/hook/utils/UtilsFactory.kt index 1e1ded28..7b723c69 100644 --- a/yukihookapi/src/api/kotlin/com/highcapable/yukihookapi/hook/utils/UtilsFactory.kt +++ b/yukihookapi/src/api/kotlin/com/highcapable/yukihookapi/hook/utils/UtilsFactory.kt @@ -29,7 +29,6 @@ package com.highcapable.yukihookapi.hook.utils import java.util.concurrent.ExecutorService import java.util.concurrent.Executors -import java.util.concurrent.TimeUnit /** * 创建当前线程池服务 @@ -60,22 +59,6 @@ internal inline fun T.await(delayMs: Long = 1, crossinline block: (T) -> Uni return this } -/** - * 进行一次并行计算的 ForEach 操作 - * @param action 回调内容方法体 - */ -internal inline fun Iterable.parallelForEach(crossinline action: (T) -> Unit) { - currentThreadPool.apply { - val iterator = iterator() - while (iterator.hasNext()) { - val item = iterator.next() - execute { runCatching { action(item) } } - } - shutdown() - awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS) - } -} - /** * 获取数组内容依次列出的字符串表示 * @return [String]