From a4f3f93fc1bb24baa27ac9163f44f5b0b02ed1ae Mon Sep 17 00:00:00 2001 From: Cedric Beust Date: Wed, 6 Jul 2016 01:58:32 -0800 Subject: [PATCH] public --- .../kotlin/com/beust/kobalt/misc/KobaltExecutors.kt | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/modules/kobalt-plugin-api/src/main/kotlin/com/beust/kobalt/misc/KobaltExecutors.kt b/modules/kobalt-plugin-api/src/main/kotlin/com/beust/kobalt/misc/KobaltExecutors.kt index f35d6835..af1e0ae2 100644 --- a/modules/kobalt-plugin-api/src/main/kotlin/com/beust/kobalt/misc/KobaltExecutors.kt +++ b/modules/kobalt-plugin-api/src/main/kotlin/com/beust/kobalt/misc/KobaltExecutors.kt @@ -5,11 +5,10 @@ import java.util.concurrent.* class NamedThreadFactory(val n: String) : ThreadFactory { private val PREFIX = "K-" - public val name: String + val name: String get() = PREFIX + n - override - public fun newThread(r: Runnable) : Thread { + override fun newThread(r: Runnable) : Thread { val result = Thread(r) result.name = name + "-" + result.id return result @@ -20,7 +19,7 @@ class KobaltExecutor(name: String, threadCount: Int) : ThreadPoolExecutor(threadCount, threadCount, 5L, TimeUnit.SECONDS, LinkedBlockingQueue(), NamedThreadFactory(name)) { - override protected fun afterExecute(r: Runnable, t: Throwable?) { + override fun afterExecute(r: Runnable, t: Throwable?) { super.afterExecute(r, t) var ex : Throwable? = null if (t == null && r is Future<*>) { @@ -40,8 +39,8 @@ class KobaltExecutor(name: String, threadCount: Int) } } -public class KobaltExecutors { - public fun newExecutor(name: String, threadCount: Int) : ExecutorService +class KobaltExecutors { + fun newExecutor(name: String, threadCount: Int) : ExecutorService = KobaltExecutor(name, threadCount) val dependencyExecutor = newExecutor("Dependency", 5)