Loading src/com/android/settings/fuelgauge/utils/LifecycleAwareExecutorFactory.kt +3 −0 Original line number Original line Diff line number Diff line Loading @@ -31,18 +31,21 @@ import java.util.concurrent.Executors */ */ object LifecycleAwareExecutorFactory { object LifecycleAwareExecutorFactory { @JvmStatic fun newSingleThreadExecutor(lifecycle: Lifecycle?): ExecutorService { fun newSingleThreadExecutor(lifecycle: Lifecycle?): ExecutorService { return Executors.newSingleThreadExecutor().also { executor -> return Executors.newSingleThreadExecutor().also { executor -> executor.autoShutdown(lifecycle) executor.autoShutdown(lifecycle) } } } } @JvmStatic fun newFixedThreadPool(lifecycle: Lifecycle?, nThreads: Int): ExecutorService { fun newFixedThreadPool(lifecycle: Lifecycle?, nThreads: Int): ExecutorService { return Executors.newFixedThreadPool(nThreads).also { executor -> return Executors.newFixedThreadPool(nThreads).also { executor -> executor.autoShutdown(lifecycle) executor.autoShutdown(lifecycle) } } } } @JvmStatic fun newCachedThreadPool(lifecycle: Lifecycle?): ExecutorService { fun newCachedThreadPool(lifecycle: Lifecycle?): ExecutorService { return Executors.newCachedThreadPool().also { executor -> return Executors.newCachedThreadPool().also { executor -> executor.autoShutdown(lifecycle) executor.autoShutdown(lifecycle) Loading Loading
src/com/android/settings/fuelgauge/utils/LifecycleAwareExecutorFactory.kt +3 −0 Original line number Original line Diff line number Diff line Loading @@ -31,18 +31,21 @@ import java.util.concurrent.Executors */ */ object LifecycleAwareExecutorFactory { object LifecycleAwareExecutorFactory { @JvmStatic fun newSingleThreadExecutor(lifecycle: Lifecycle?): ExecutorService { fun newSingleThreadExecutor(lifecycle: Lifecycle?): ExecutorService { return Executors.newSingleThreadExecutor().also { executor -> return Executors.newSingleThreadExecutor().also { executor -> executor.autoShutdown(lifecycle) executor.autoShutdown(lifecycle) } } } } @JvmStatic fun newFixedThreadPool(lifecycle: Lifecycle?, nThreads: Int): ExecutorService { fun newFixedThreadPool(lifecycle: Lifecycle?, nThreads: Int): ExecutorService { return Executors.newFixedThreadPool(nThreads).also { executor -> return Executors.newFixedThreadPool(nThreads).also { executor -> executor.autoShutdown(lifecycle) executor.autoShutdown(lifecycle) } } } } @JvmStatic fun newCachedThreadPool(lifecycle: Lifecycle?): ExecutorService { fun newCachedThreadPool(lifecycle: Lifecycle?): ExecutorService { return Executors.newCachedThreadPool().also { executor -> return Executors.newCachedThreadPool().also { executor -> executor.autoShutdown(lifecycle) executor.autoShutdown(lifecycle) Loading