Loading services/appfunctions/java/com/android/server/appfunctions/AppFunctionExecutors.java +10 −5 Original line number Diff line number Diff line Loading @@ -16,7 +16,6 @@ package com.android.server.appfunctions; import java.util.concurrent.Executor; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; Loading @@ -24,15 +23,21 @@ import java.util.concurrent.TimeUnit; /** Executors for App function operations. */ public final class AppFunctionExecutors { static final int sConcurrency = Runtime.getRuntime().availableProcessors(); /** Executor for operations that do not need to block. */ public static final Executor THREAD_POOL_EXECUTOR = public static final ThreadPoolExecutor THREAD_POOL_EXECUTOR = new ThreadPoolExecutor( /* corePoolSize= */ Runtime.getRuntime().availableProcessors(), /* maxConcurrency= */ Runtime.getRuntime().availableProcessors(), /* keepAliveTime= */ 0L, /* corePoolSize= */ sConcurrency, /* maxConcurrency= */ sConcurrency, /* keepAliveTime= */ 1L, /* unit= */ TimeUnit.SECONDS, /* workQueue= */ new LinkedBlockingQueue<>(), new NamedThreadFactory("AppFunctionExecutors")); static { THREAD_POOL_EXECUTOR.allowCoreThreadTimeOut(true); } private AppFunctionExecutors() {} } Loading
services/appfunctions/java/com/android/server/appfunctions/AppFunctionExecutors.java +10 −5 Original line number Diff line number Diff line Loading @@ -16,7 +16,6 @@ package com.android.server.appfunctions; import java.util.concurrent.Executor; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; Loading @@ -24,15 +23,21 @@ import java.util.concurrent.TimeUnit; /** Executors for App function operations. */ public final class AppFunctionExecutors { static final int sConcurrency = Runtime.getRuntime().availableProcessors(); /** Executor for operations that do not need to block. */ public static final Executor THREAD_POOL_EXECUTOR = public static final ThreadPoolExecutor THREAD_POOL_EXECUTOR = new ThreadPoolExecutor( /* corePoolSize= */ Runtime.getRuntime().availableProcessors(), /* maxConcurrency= */ Runtime.getRuntime().availableProcessors(), /* keepAliveTime= */ 0L, /* corePoolSize= */ sConcurrency, /* maxConcurrency= */ sConcurrency, /* keepAliveTime= */ 1L, /* unit= */ TimeUnit.SECONDS, /* workQueue= */ new LinkedBlockingQueue<>(), new NamedThreadFactory("AppFunctionExecutors")); static { THREAD_POOL_EXECUTOR.allowCoreThreadTimeOut(true); } private AppFunctionExecutors() {} }