/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/android/guava/src/com/google/common/util/concurrent/ |
D | JdkFutureAdapters.java | 99 private static final ThreadFactory threadFactory = field in JdkFutureAdapters.ListenableFutureAdapter 105 Executors.newCachedThreadPool(threadFactory);
|
/external/guava/guava/src/com/google/common/util/concurrent/ |
D | JdkFutureAdapters.java | 99 private static final ThreadFactory threadFactory = field in JdkFutureAdapters.ListenableFutureAdapter 105 Executors.newCachedThreadPool(threadFactory);
|
/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/android/guava-tests/test/com/google/common/util/concurrent/ |
D | MoreExecutorsTest.java | 594 ThreadFactory threadFactory = mock(ThreadFactory.class); in testGetExitingExecutorService_executorDelegatesToOriginal() local 595 when(executor.getThreadFactory()).thenReturn(threadFactory); in testGetExitingExecutorService_executorDelegatesToOriginal() 603 ThreadFactory threadFactory = mock(ThreadFactory.class); in testGetExitingExecutorService_shutdownHookRegistered() local 604 when(executor.getThreadFactory()).thenReturn(threadFactory); in testGetExitingExecutorService_shutdownHookRegistered() 620 ThreadFactory threadFactory = mock(ThreadFactory.class); in testGetExitingScheduledExecutorService_executorDelegatesToOriginal() local 621 when(executor.getThreadFactory()).thenReturn(threadFactory); in testGetExitingScheduledExecutorService_executorDelegatesToOriginal() 630 ThreadFactory threadFactory = mock(ThreadFactory.class); in testGetScheduledExitingExecutorService_shutdownHookRegistered() local 631 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/guava-tests/test/com/google/common/util/concurrent/ |
D | MoreExecutorsTest.java | 594 ThreadFactory threadFactory = mock(ThreadFactory.class); in testGetExitingExecutorService_executorDelegatesToOriginal() local 595 when(executor.getThreadFactory()).thenReturn(threadFactory); in testGetExitingExecutorService_executorDelegatesToOriginal() 603 ThreadFactory threadFactory = mock(ThreadFactory.class); in testGetExitingExecutorService_shutdownHookRegistered() local 604 when(executor.getThreadFactory()).thenReturn(threadFactory); in testGetExitingExecutorService_shutdownHookRegistered() 620 ThreadFactory threadFactory = mock(ThreadFactory.class); in testGetExitingScheduledExecutorService_executorDelegatesToOriginal() local 621 when(executor.getThreadFactory()).thenReturn(threadFactory); in testGetExitingScheduledExecutorService_executorDelegatesToOriginal() 630 ThreadFactory threadFactory = mock(ThreadFactory.class); in testGetScheduledExitingExecutorService_shutdownHookRegistered() local 631 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/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/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/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/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-ws/src/main/java/com/squareup/okhttp/ws/ |
D | WebSocketCall.java | 164 Util.threadFactory(String.format("OkHttp %s WebSocket", url), true)); in create()
|
/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-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
D | MockSpdyPeer.java | 54 Util.threadFactory("MockSpdyPeer", false));
|
/external/okhttp/repackaged/okhttp/src/main/java/com/android/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/ |
D | Util.java | 222 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()
|
/external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/ |
D | MockWebServer.java | 349 executor = Executors.newCachedThreadPool(Util.threadFactory("MockWebServer", false)); 674 Util.threadFactory(String.format("MockWebServer %s WebSocket", request.getPath()),
|