Home
last modified time | relevance | path

Searched refs:threadFactory (Results 1 – 25 of 32) sorted by relevance

12

/external/apache-commons-io/src/main/java/org/apache/commons/io/monitor/
DFileAlterationMonitor.java44 private ThreadFactory threadFactory; field in FileAlterationMonitor
161 public synchronized void setThreadFactory(final ThreadFactory threadFactory) { in setThreadFactory() argument
162 this.threadFactory = threadFactory; in setThreadFactory()
178 if (threadFactory != null) { in start()
179 thread = threadFactory.newThread(this); in start()
/external/downloader/src/test/java/com/google/android/downloader/
DTestExecutorRule.java42 private final ThreadFactory threadFactory = field in TestExecutorRule
68 ExecutorService executorService = Executors.newSingleThreadExecutor(threadFactory); in newSingleThreadExecutor()
82 Executors.newSingleThreadScheduledExecutor(threadFactory); in newSingleThreadScheduledExecutor()
/external/opencensus-java/impl_core/src/main/java/io/opencensus/implcore/internal/
DDaemonThreadFactory.java31 private static final ThreadFactory threadFactory = MoreExecutors.platformThreadFactory(); field in DaemonThreadFactory
46 Thread thread = threadFactory.newThread(r); in newThread()
/external/vogar/src/vogar/util/
DThreads.java48 ThreadFactory threadFactory = daemonThreadFactory(name); in fixedThreadsExecutor() local
51 new LinkedBlockingQueue<Runnable>(Integer.MAX_VALUE), threadFactory) { in fixedThreadsExecutor()
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DMoreExecutorsTest.java597 ThreadFactory threadFactory = mock(ThreadFactory.class); in testGetExitingExecutorService_executorDelegatesToOriginal() local
598 when(executor.getThreadFactory()).thenReturn(threadFactory); in testGetExitingExecutorService_executorDelegatesToOriginal()
607 ThreadFactory threadFactory = mock(ThreadFactory.class); in testGetExitingExecutorService_shutdownHookRegistered() local
608 when(executor.getThreadFactory()).thenReturn(threadFactory); in testGetExitingExecutorService_shutdownHookRegistered()
625 ThreadFactory threadFactory = mock(ThreadFactory.class); in testGetExitingScheduledExecutorService_executorDelegatesToOriginal() local
626 when(executor.getThreadFactory()).thenReturn(threadFactory); in testGetExitingScheduledExecutorService_executorDelegatesToOriginal()
636 ThreadFactory threadFactory = mock(ThreadFactory.class); in testGetScheduledExitingExecutorService_shutdownHookRegistered() local
637 when(executor.getThreadFactory()).thenReturn(threadFactory); in testGetScheduledExitingExecutorService_shutdownHookRegistered()
DThreadFactoryBuilderTest.java60 ThreadFactory threadFactory = builder.build(); in testThreadFactoryBuilder_defaults() local
61 Thread thread = threadFactory.newThread(monitoredRunnable); in testThreadFactoryBuilder_defaults()
77 Thread thread2 = threadFactory.newThread(monitoredRunnable); in testThreadFactoryBuilder_defaults()
/external/guava/android/guava-tests/test/com/google/common/util/concurrent/
DMoreExecutorsTest.java597 ThreadFactory threadFactory = mock(ThreadFactory.class); in testGetExitingExecutorService_executorDelegatesToOriginal() local
598 when(executor.getThreadFactory()).thenReturn(threadFactory); in testGetExitingExecutorService_executorDelegatesToOriginal()
607 ThreadFactory threadFactory = mock(ThreadFactory.class); in testGetExitingExecutorService_shutdownHookRegistered() local
608 when(executor.getThreadFactory()).thenReturn(threadFactory); in testGetExitingExecutorService_shutdownHookRegistered()
625 ThreadFactory threadFactory = mock(ThreadFactory.class); in testGetExitingScheduledExecutorService_executorDelegatesToOriginal() local
626 when(executor.getThreadFactory()).thenReturn(threadFactory); in testGetExitingScheduledExecutorService_executorDelegatesToOriginal()
636 ThreadFactory threadFactory = mock(ThreadFactory.class); in testGetScheduledExitingExecutorService_shutdownHookRegistered() local
637 when(executor.getThreadFactory()).thenReturn(threadFactory); in testGetScheduledExitingExecutorService_shutdownHookRegistered()
DThreadFactoryBuilderTest.java60 ThreadFactory threadFactory = builder.build(); in testThreadFactoryBuilder_defaults() local
61 Thread thread = threadFactory.newThread(monitoredRunnable); in testThreadFactoryBuilder_defaults()
77 Thread thread2 = threadFactory.newThread(monitoredRunnable); in testThreadFactoryBuilder_defaults()
/external/glide/library/src/main/java/com/bumptech/glide/load/engine/executor/
DFifoPriorityThreadPoolExecutor.java31 ThreadFactory threadFactory) { in FifoPriorityThreadPoolExecutor() argument
32 …lSize, maximumPoolSize, keepAlive, timeUnit, new PriorityBlockingQueue<Runnable>(), threadFactory); in FifoPriorityThreadPoolExecutor()
/external/guava/guava/src/com/google/common/util/concurrent/
DJdkFutureAdapters.java103 private static final ThreadFactory threadFactory = field in JdkFutureAdapters.ListenableFutureAdapter
109 Executors.newCachedThreadPool(threadFactory);
/external/guava/android/guava/src/com/google/common/util/concurrent/
DJdkFutureAdapters.java103 private static final ThreadFactory threadFactory = field in JdkFutureAdapters.ListenableFutureAdapter
109 Executors.newCachedThreadPool(threadFactory);
/external/cronet/base/android/java/src/org/chromium/base/task/
DChromeThreadPoolExecutor.java55 TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory) { in ChromeThreadPoolExecutor() argument
56 super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, threadFactory); in ChromeThreadPoolExecutor()
/external/opencensus-java/exporters/stats/stackdriver/src/main/java/io/opencensus/exporter/stats/stackdriver/
DStackdriverStatsExporter.java351 private static final ThreadFactory threadFactory = MoreExecutors.platformThreadFactory(); field in StackdriverStatsExporter.DaemonThreadFactory
355 Thread thread = threadFactory.newThread(r); in newThread()
/external/apache-commons-io/src/test/java/org/apache/commons/io/monitor/
DFileAlterationMonitorTest.java179 final ThreadFactory threadFactory = new ThreadFactory() { in testStopWhileWaitingForNextInterval() local
192 monitor.setThreadFactory(threadFactory); in testStopWhileWaitingForNextInterval()
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DUtils.java195 ThreadFactory threadFactory = new DefaultThreadFactory(name, useDaemonThreads); in create() local
198 return new NioEventLoopGroup(parallelism, threadFactory); in create()
/external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/
DDispatcher.java64 new SynchronousQueue<Runnable>(), Util.threadFactory("OkHttp Dispatcher", false)); in getExecutorService()
DConnectionPool.java89 new LinkedBlockingQueue<Runnable>(), Util.threadFactory("OkHttp ConnectionPool", true));
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/
DDispatcher.java62 new SynchronousQueue<Runnable>(), Util.threadFactory("OkHttp Dispatcher", false)); in getExecutorService()
DConnectionPool.java86 new LinkedBlockingQueue<Runnable>(), Util.threadFactory("OkHttp ConnectionPool", true));
/external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/ws/
DWebSocketCall.java164 Util.threadFactory(String.format("OkHttp %s WebSocket", url), true)); in create()
/external/robolectric/shadows/framework/src/main/java/org/robolectric/shadows/
DShadowLegacySQLiteConnection.java397 private ExecutorService dbExecutor = Executors.newSingleThreadExecutor(threadFactory());
399 static ThreadFactory threadFactory() { in threadFactory() method in ShadowLegacySQLiteConnection.Connections
518 dbExecutor = Executors.newSingleThreadExecutor(threadFactory()); in reset()
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/
DSocksProxy.java57 Util.threadFactory("SocksProxy", false));
/external/grpc-grpc-java/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/
DUtil.java228 public static ThreadFactory threadFactory(final String name, final boolean daemon) { in threadFactory() method in Util
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/
DFramedConnection.java71 Util.threadFactory("OkHttp FramedConnection", true));
159 Util.threadFactory(String.format("OkHttp %s Push Observer", hostName), true)); in FramedConnection()
/external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/
DFramedConnection.java73 Util.threadFactory("OkHttp FramedConnection", true));
161 Util.threadFactory(String.format("OkHttp %s Push Observer", hostName), true)); in FramedConnection()

12