Home
last modified time | relevance | path

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

12

/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/android/guava/src/com/google/common/util/concurrent/
DJdkFutureAdapters.java99 private static final ThreadFactory threadFactory = field in JdkFutureAdapters.ListenableFutureAdapter
105 Executors.newCachedThreadPool(threadFactory);
/external/guava/guava/src/com/google/common/util/concurrent/
DJdkFutureAdapters.java99 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/
DFifoPriorityThreadPoolExecutor.java31 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/
DMoreExecutorsTest.java594 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()
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/guava-tests/test/com/google/common/util/concurrent/
DMoreExecutorsTest.java594 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()
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/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/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/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/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-ws/src/main/java/com/squareup/okhttp/ws/
DWebSocketCall.java164 Util.threadFactory(String.format("OkHttp %s WebSocket", url), true)); in create()
/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-tests/src/test/java/com/squareup/okhttp/internal/framed/
DMockSpdyPeer.java54 Util.threadFactory("MockSpdyPeer", false));
/external/okhttp/repackaged/okhttp/src/main/java/com/android/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/
DUtil.java222 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()
/external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/
DMockWebServer.java349 executor = Executors.newCachedThreadPool(Util.threadFactory("MockWebServer", false));
674 Util.threadFactory(String.format("MockWebServer %s WebSocket", request.getPath()),

12