/external/apache-commons-io/src/main/java/org/apache/commons/io/monitor/ |
D | FileAlterationMonitor.java | 44 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/ |
D | TestExecutorRule.java | 42 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/ |
D | DaemonThreadFactory.java | 31 private static final ThreadFactory threadFactory = MoreExecutors.platformThreadFactory(); field in DaemonThreadFactory 46 Thread thread = threadFactory.newThread(r); in newThread()
|
/external/vogar/src/vogar/util/ |
D | Threads.java | 48 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/ |
D | MoreExecutorsTest.java | 597 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()
|
D | ThreadFactoryBuilderTest.java | 60 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/ |
D | MoreExecutorsTest.java | 597 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()
|
D | ThreadFactoryBuilderTest.java | 60 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/ |
D | FifoPriorityThreadPoolExecutor.java | 31 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/ |
D | JdkFutureAdapters.java | 103 private static final ThreadFactory threadFactory = field in JdkFutureAdapters.ListenableFutureAdapter 109 Executors.newCachedThreadPool(threadFactory);
|
/external/guava/android/guava/src/com/google/common/util/concurrent/ |
D | JdkFutureAdapters.java | 103 private static final ThreadFactory threadFactory = field in JdkFutureAdapters.ListenableFutureAdapter 109 Executors.newCachedThreadPool(threadFactory);
|
/external/cronet/base/android/java/src/org/chromium/base/task/ |
D | ChromeThreadPoolExecutor.java | 55 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/ |
D | StackdriverStatsExporter.java | 351 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/ |
D | FileAlterationMonitorTest.java | 179 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/ |
D | Utils.java | 195 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/ |
D | Dispatcher.java | 64 new SynchronousQueue<Runnable>(), Util.threadFactory("OkHttp Dispatcher", false)); in getExecutorService()
|
D | ConnectionPool.java | 89 new LinkedBlockingQueue<Runnable>(), Util.threadFactory("OkHttp ConnectionPool", true));
|
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
D | Dispatcher.java | 62 new SynchronousQueue<Runnable>(), Util.threadFactory("OkHttp Dispatcher", false)); in getExecutorService()
|
D | ConnectionPool.java | 86 new LinkedBlockingQueue<Runnable>(), Util.threadFactory("OkHttp ConnectionPool", true));
|
/external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/ws/ |
D | WebSocketCall.java | 164 Util.threadFactory(String.format("OkHttp %s WebSocket", url), true)); in create()
|
/external/robolectric/shadows/framework/src/main/java/org/robolectric/shadows/ |
D | ShadowLegacySQLiteConnection.java | 397 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/ |
D | SocksProxy.java | 57 Util.threadFactory("SocksProxy", false));
|
/external/grpc-grpc-java/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/ |
D | Util.java | 228 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/ |
D | FramedConnection.java | 71 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/ |
D | FramedConnection.java | 73 Util.threadFactory("OkHttp FramedConnection", true)); 161 Util.threadFactory(String.format("OkHttp %s Push Observer", hostName), true)); in FramedConnection()
|