| /libcore/jsr166-tests/src/test/java/jsr166/ |
| DelayQueueTest.java | 670 * timed poll transfers elements across Executor tasks
675 final ExecutorService executor = Executors.newFixedThreadPool(2); local
676 try (PoolCleaner cleaner = cleaner(executor)) {
677 executor.execute(new CheckedRunnable() {
685 executor.execute(new CheckedRunnable() {
|
| LinkedBlockingQueueTest.java | 724 * offer transfers elements across Executor tasks
731 final ExecutorService executor = Executors.newFixedThreadPool(2); local
732 try (PoolCleaner cleaner = cleaner(executor)) {
733 executor.execute(new CheckedRunnable() {
741 executor.execute(new CheckedRunnable() {
750 * timed poll retrieves elements across Executor threads
755 final ExecutorService executor = Executors.newFixedThreadPool(2); local
756 try (PoolCleaner cleaner = cleaner(executor)) {
757 executor.execute(new CheckedRunnable() {
765 executor.execute(new CheckedRunnable()
[all...] |
| PriorityBlockingQueueTest.java | 627 * timed poll transfers elements across Executor tasks
632 final ExecutorService executor = Executors.newFixedThreadPool(2); local
633 try (PoolCleaner cleaner = cleaner(executor)) {
634 executor.execute(new CheckedRunnable() {
642 executor.execute(new CheckedRunnable() {
|
| ArrayBlockingQueueTest.java | 790 * offer transfers elements across Executor tasks
797 final ExecutorService executor = Executors.newFixedThreadPool(2); local
798 try (PoolCleaner cleaner = cleaner(executor)) {
799 executor.execute(new CheckedRunnable() {
807 executor.execute(new CheckedRunnable() {
817 * timed poll retrieves elements across Executor threads
822 final ExecutorService executor = Executors.newFixedThreadPool(2); local
823 try (PoolCleaner cleaner = cleaner(executor)) {
824 executor.execute(new CheckedRunnable() {
832 executor.execute(new CheckedRunnable()
[all...] |
| LinkedTransferQueueTest.java | 599 * offer transfers elements across Executor tasks
604 final ExecutorService executor = Executors.newFixedThreadPool(2); local
605 try (PoolCleaner cleaner = cleaner(executor)) {
607 executor.execute(new CheckedRunnable() {
615 executor.execute(new CheckedRunnable() {
625 * timed poll retrieves elements across Executor threads
630 final ExecutorService executor = Executors.newFixedThreadPool(2); local
631 try (PoolCleaner cleaner = cleaner(executor)) {
633 executor.execute(new CheckedRunnable() {
643 executor.execute(new CheckedRunnable()
[all...] |
| /external/antlr/antlr-3.4/gunit-maven-plugin/src/main/java/org/antlr/mojo/antlr3/ |
| GUnitExecuteMojo.java | 299 gUnitExecutor executor = new gUnitExecutor( local
305 String report = executor.execTest();
309 testResult.tests = executor.numOfTest;
310 testResult.failures = executor.numOfFailure;
311 testResult.invalids = executor.numOfInvalidInput;
316 for ( AbstractTest test : executor.failures ) {
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| InterceptorTest.java | 547 ExceptionCatchingExecutor executor = new ExceptionCatchingExecutor(); local
548 client.setDispatcher(new Dispatcher(executor));
555 assertEquals("boom!", executor.takeException().getMessage());
569 ExceptionCatchingExecutor executor = new ExceptionCatchingExecutor(); local
570 client.setDispatcher(new Dispatcher(executor));
595 ExceptionCatchingExecutor executor = new ExceptionCatchingExecutor(); local
596 client.setDispatcher(new Dispatcher(executor));
|
| /libcore/support/src/test/java/tests/http/ |
| MockWebServer.java | 77 private ExecutorService executor; field in class:MockWebServer
177 executor = Executors.newCachedThreadPool();
182 executor.execute(namedRunnable("MockWebServer-accept-" + port, new Runnable() {
208 executor.shutdown();
210 logger.log(Level.WARNING, "MockWebServer executor shutdown failed", e);
243 executor.execute(namedRunnable(name, new Runnable() {
|
| /packages/services/Mms/src/com/android/mms/service/ |
| MmsService.java | 478 for (ExecutorService executor : mRunningRequestExecutors) {
479 executor.shutdown();
[all...] |
| /prebuilts/tools/common/m2/repository/io/grpc/grpc-auth/0.13.2/ |
| grpc-auth-0.13.2.jar | |
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
| FramedConnection.java | 69 private static final ExecutorService executor = new ThreadPoolExecutor(0, field in class:FramedConnection
81 * on {@link #executor}.
349 executor.submit(new NamedRunnable("OkHttp %s stream %d", hostName, streamId) {
364 executor.execute(new NamedRunnable("OkHttp Window Update %s stream %d", hostName, streamId) {
396 executor.execute(new NamedRunnable("OkHttp %s ping %08x%08x",
447 * internal executor services.
672 executor.execute(new NamedRunnable("OkHttp %s stream %d", hostName, streamId) {
733 executor.execute(new NamedRunnable("OkHttp %s settings", hostName) {
749 executor.execute(new NamedRunnable("OkHttp %s ACK Settings", hostName) {
[all...] |
| /external/webrtc/webrtc/examples/androidapp/src/org/appspot/apprtc/ |
| PeerConnectionClient.java | 92 private final LooperExecutor executor; field in class:PeerConnectionClient
215 executor = new LooperExecutor();
219 executor.requestStart();
252 executor.execute(new Runnable() {
272 executor.execute(new Runnable() {
282 executor.execute(new Runnable() {
587 executor.execute(new Runnable() {
604 executor.execute(new Runnable() {
619 executor.execute(new Runnable() {
632 executor.execute(new Runnable()
[all...] |
| /cts/tests/sensor/src/android/hardware/cts/ |
| SensorTest.java | 425 FlushExecutor executor = new FlushExecutor(environment, 500 /* eventCount */); local
426 parallelSensorOperation.add(new TestSensorOperation(environment, executor));
534 FlushExecutor executor = new FlushExecutor(environment, 500 /* eventCount */); local
535 TestSensorOperation operation = new TestSensorOperation(environment, executor, handler);
568 private class FlushExecutor implements TestSensorOperation.Executor {
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| MoreExecutors.java | 39 import java.util.concurrent.Executor;
57 * Factory and utility methods for {@link java.util.concurrent.Executor}, {@link
76 * @param executor the executor to modify to make sure it exits when the
78 * @param terminationTimeout how long to wait for the executor to
85 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) {
87 .getExitingExecutorService(executor, terminationTimeout, timeUnit);
99 * @param executor the executor to modify to make sure it exits when the
101 * @param terminationTimeout how long to wait for the executor t
[all...] |
| /external/testng/src/main/java/org/testng/ |
| TestRunner.java | 737 * graph executor to run them.
752 GraphThreadPoolExecutor<ITestNGMethod> executor = local
756 executor.run();
759 Utils.log("TestRunner", 2, "Starting executor for test " + m_xmlTest.getName()
761 executor.awaitTermination(timeOut, TimeUnit.MILLISECONDS);
762 executor.shutdownNow();
[all...] |
| /cts/tests/tests/keystore/src/android/keystore/cts/ |
| KeyPairGeneratorTest.java | 1422 ExecutorService executor = Executors.newSingleThreadExecutor(); local
[all...] |
| /external/conscrypt/platform/src/test/java/org/conscrypt/ |
| TrustedCertificateStoreTest.java | 740 ExecutorService executor = Executors.newSingleThreadExecutor(); local
741 Future<List<X509Certificate>> future = executor
748 executor.shutdown();
[all...] |
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/util/jar/ |
| JarFileTest.java | 657 ExecutorService executor = Executors.newSingleThreadExecutor(); local
658 Future<Boolean> future = executor.submit(new Callable<Boolean>() {
681 executor.shutdown();
[all...] |
| /libcore/luni/src/test/java/libcore/java/net/ |
| SocketTest.java | 483 private ExecutorService executor; field in class:SocketTest.MockServer
488 executor = Executors.newCachedThreadPool();
496 return executor.submit(new Callable<byte[]>() {
516 executor.shutdown();
|
| /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/io/netty/netty-transport/4.1.3.Final/ |
| netty-transport-4.1.3.Final.jar | |
| /prebuilts/tools/common/m2/repository/io/grpc/grpc-context/1.0.1/ |
| grpc-context-1.0.1.jar | |
| /prebuilts/tools/common/m2/repository/io/grpc/grpc-context/1.0.3/ |
| grpc-context-1.0.3.jar | |
| /external/eclipse-basebuilder/basebuilder-3.6.2/org.eclipse.releng.basebuilder/configuration/org.eclipse.osgi/bundles/118/1/.cp/lib/ |
| jarprocessor-ant.jar | |
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| AbstractScheduledServiceTest.java | 51 final ScheduledExecutorService executor = new ScheduledThreadPoolExecutor(10) { field in class:AbstractScheduledServiceTest
70 @Override protected ScheduledExecutorService executor() { return executor; } method in class:AbstractScheduledServiceTest.NullService
152 final AtomicReference<ScheduledExecutorService> executor = Atomics.newReference(); local
156 @Override protected ScheduledExecutorService executor() {
157 executor.set(super.executor());
158 return executor.get();
167 assertFalse(service.executor().isShutdown());
171 assertTrue(executor.get().awaitTermination(100, TimeUnit.MILLISECONDS))
175 final AtomicReference<ScheduledExecutorService> executor = Atomics.newReference(); local
267 protected ScheduledExecutorService executor() { method in class:AbstractScheduledServiceTest.TestService
415 @Override protected ScheduledExecutorService executor() { method in class:AbstractScheduledServiceTest.SchedulerTest.TestAbstractScheduledCustomService
461 @Override protected ScheduledExecutorService executor() { method in class:TestFailingCustomScheduledService
[all...] |
