| /cts/libs/vogar-expect/src/vogar/util/ |
| Threads.java | 21 import java.util.concurrent.ThreadFactory;
31 public static ThreadFactory daemonThreadFactory(final String name) {
32 return new ThreadFactory() {
47 ThreadFactory threadFactory = daemonThreadFactory(name);
50 new LinkedBlockingQueue<Runnable>(Integer.MAX_VALUE), threadFactory) {
|
| /external/vogar/src/vogar/util/ |
| Threads.java | 21 import java.util.concurrent.ThreadFactory;
32 public static ThreadFactory daemonThreadFactory(final String name) {
33 return new ThreadFactory() {
48 ThreadFactory threadFactory = daemonThreadFactory(name);
51 new LinkedBlockingQueue<Runnable>(Integer.MAX_VALUE), threadFactory) {
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| JdkFutureAdapters.java | 27 import java.util.concurrent.ThreadFactory;
112 private static final ThreadFactory threadFactory =
118 Executors.newCachedThreadPool(threadFactory);
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| ThreadPool.java | 39 "java.nio.channels.DefaultThreadPool.threadFactory";
73 static ThreadFactory defaultThreadFactory() {
117 ThreadFactory threadFactory = getDefaultThreadPoolThreadFactory();
118 if (threadFactory == null)
119 threadFactory = defaultThreadFactory();
121 ExecutorService executor = Executors.newCachedThreadPool(threadFactory);
126 static ThreadPool create(int nThreads, ThreadFactory factory) {
170 private static ThreadFactory getDefaultThreadPoolThreadFactory() {
177 return ((ThreadFactory)c.newInstance())
[all...] |
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/ |
| Util.java | 36 import java.util.concurrent.ThreadFactory;
222 public static ThreadFactory threadFactory(final String name, final boolean daemon) {
223 return new ThreadFactory() {
|
| /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/ |
| QsbApplication.java | 44 import java.util.concurrent.ThreadFactory;
54 private ThreadFactory mQueryThreadFactory;
140 ThreadFactory iconThreadFactory = new PriorityThreadFactory(
179 final ThreadFactory threadFactory = getQueryThreadFactory();
183 return Executors.newFixedThreadPool(numThreads, threadFactory);
202 ThreadFactory queryThreadFactory = getQueryThreadFactory();
210 protected ThreadFactory getQueryThreadFactory() {
218 protected ThreadFactory createQueryThreadFactory() {
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| ThreadFactoryBuilderTest.java | 27 import java.util.concurrent.ThreadFactory;
57 ThreadFactory threadFactory = builder.build();
58 Thread thread = threadFactory.newThread(monitoredRunnable);
74 // Creating a new thread from the same ThreadFactory will have the same
76 Thread thread2 = threadFactory.newThread(monitoredRunnable);
83 ThreadFactory threadFactory2 = builder.build();
98 ThreadFactory factory = builder.setNameFormat(format).build();
107 ThreadFactory factory = builder.setNameFormat(format).build();
115 ThreadFactory factory = builder.setDaemon(false).build()
[all...] |
| MoreExecutorsTest.java | 72 import java.util.concurrent.ThreadFactory;
543 ThreadFactory threadFactory = mock(ThreadFactory.class);
544 when(executor.getThreadFactory()).thenReturn(threadFactory);
552 ThreadFactory threadFactory = mock(ThreadFactory.class);
553 when(executor.getThreadFactory()).thenReturn(threadFactory);
569 ThreadFactory threadFactory = mock(ThreadFactory.class)
[all...] |
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| ThreadPoolExecutor.java | 115 * New threads are created using a {@link ThreadFactory}. If not
119 * non-daemon status. By supplying a different ThreadFactory, you can
121 * etc. If a {@code ThreadFactory} fails to create a thread when asked
356 * for example when a ThreadFactory fails to create a thread when
532 private volatile ThreadFactory threadFactory;
630 * Creates with given first task and thread from ThreadFactory.
[all...] |
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| ScheduledExecutorSubclassTest.java | 30 import java.util.concurrent.ThreadFactory;
96 CustomExecutor(int corePoolSize, ThreadFactory threadFactory) {
97 super(corePoolSize, threadFactory);
99 CustomExecutor(int corePoolSize, ThreadFactory threadFactory,
101 super(corePoolSize, threadFactory, handler);
538 final ThreadFactory threadFactory = new SimpleThreadFactory();
539 final CustomExecutor p = new CustomExecutor(1, threadFactory);
[all...] |
| ScheduledExecutorTest.java | 29 import java.util.concurrent.ThreadFactory;
482 final ThreadFactory threadFactory = new SimpleThreadFactory();
484 new ScheduledThreadPoolExecutor(1, threadFactory);
486 assertSame(threadFactory, p.getThreadFactory());
494 ThreadFactory threadFactory = new SimpleThreadFactory();
497 p.setThreadFactory(threadFactory);
498 assertSame(threadFactory, p.getThreadFactory());
[all...] |
| ThreadPoolExecutorSubclassTest.java | 31 import java.util.concurrent.ThreadFactory;
173 ThreadFactory threadFactory) {
175 threadFactory);
192 ThreadFactory threadFactory,
195 workQueue, threadFactory, handler);
226 static class FailingThreadFactory implements ThreadFactory {
387 final ThreadFactory threadFactory = new SimpleThreadFactory()
[all...] |
| ThreadPoolExecutorTest.java | 31 import java.util.concurrent.ThreadFactory;
79 static class FailingThreadFactory implements ThreadFactory {
240 ThreadFactory threadFactory = new SimpleThreadFactory();
245 threadFactory,
248 assertSame(threadFactory, p.getThreadFactory());
261 ThreadFactory threadFactory = new SimpleThreadFactory();
262 p.setThreadFactory(threadFactory);
263 assertSame(threadFactory, p.getThreadFactory())
[all...] |
| /prebuilts/tools/common/m2/repository/com/firebase/tubesock/0.0.12/ |
| tubesock-0.0.12.jar | |
| /prebuilts/tools/common/m2/repository/io/netty/netty-transport/4.1.3.Final/ |
| netty-transport-4.1.3.Final.jar | |
| /prebuilts/tools/common/m2/repository/io/netty/netty-transport/4.1.6.Final/ |
| netty-transport-4.1.6.Final.jar | |
| /prebuilts/tools/common/m2/repository/com/parse/bolts/bolts-tasks/1.4.0/ |
| bolts-tasks-1.4.0.jar | |
| /prebuilts/tools/common/m2/repository/io/netty/netty-transport/4.1.0.CR3/ |
| netty-transport-4.1.0.CR3.jar | |
| /prebuilts/tools/common/m2/repository/io/netty/netty-common/4.1.3.Final/ |
| netty-common-4.1.3.Final.jar | |
| /prebuilts/tools/common/m2/repository/io/netty/netty-common/4.1.6.Final/ |
| netty-common-4.1.6.Final.jar | |
| /prebuilts/tools/common/m2/repository/io/netty/netty-common/4.1.0.CR3/ |
| netty-common-4.1.0.CR3.jar | |
| /prebuilts/misc/common/robolectric/3.1.1/lib/ |
| backport-util-concurrent-3.1.jar | |
| /prebuilts/tools/common/m2/repository/backport-util-concurrent/backport-util-concurrent/3.1/ |
| backport-util-concurrent-3.1.jar | |
| /prebuilts/tools/common/m2/repository/io/reactivex/rxjava/1.2.3/ |
| rxjava-1.2.3.jar | |
| /prebuilts/tools/common/m2/repository/io/reactivex/rxjava/1.1.4/ |
| rxjava-1.1.4.jar | |
