HomeSort by relevance Sort by last modified time
    Searched defs:executor (Results 51 - 75 of 159) sorted by null

1 23 4 5 6 7

  /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/
SpdyConnection.java 67 private static final ExecutorService executor = new ThreadPoolExecutor(0, field in class:SpdyConnection
79 * run on the callback executor.
327 executor.submit(new NamedRunnable("OkHttp %s stream %d", hostName, streamId) {
342 executor.submit(new NamedRunnable("OkHttp Window Update %s stream %d", hostName, streamId) {
374 executor.submit(new NamedRunnable("OkHttp %s ping %08x%08x",
425 * internal executor services.
617 executor.submit(new NamedRunnable("OkHttp %s stream %d", hostName, streamId) {
685 executor.submit(new NamedRunnable("OkHttp %s ACK Settings", hostName) {
772 executor.submit(new NamedRunnable("OkHttp %s Push Request[%s]", hostName, streamId) {
790 executor.submit(new NamedRunnable("OkHttp %s Push Headers[%s]", hostName, streamId)
    [all...]
  /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/http/
HttpOverSpdyTest.java 217 ExecutorService executor = Executors.newCachedThreadPool(); local
219 executor.execute(new SpdyRequest("/r1", countDownLatch));
220 executor.execute(new SpdyRequest("/r2", countDownLatch));
  /libcore/jsr166-tests/src/test/java/jsr166/
DelayQueueTest.java 636 * timed poll transfers elements across Executor tasks
641 ExecutorService executor = Executors.newFixedThreadPool(2); local
642 executor.execute(new CheckedRunnable() {
650 executor.execute(new CheckedRunnable() {
656 joinPool(executor);
LinkedBlockingQueueTest.java 682 * offer transfers elements across Executor tasks
688 ExecutorService executor = Executors.newFixedThreadPool(2); local
690 executor.execute(new CheckedRunnable() {
698 executor.execute(new CheckedRunnable() {
704 joinPool(executor);
708 * timed poll retrieves elements across Executor threads
713 ExecutorService executor = Executors.newFixedThreadPool(2); local
714 executor.execute(new CheckedRunnable() {
722 executor.execute(new CheckedRunnable() {
728 joinPool(executor);
    [all...]
PriorityBlockingQueueTest.java 597 * timed poll transfers elements across Executor tasks
602 ExecutorService executor = Executors.newFixedThreadPool(2); local
603 executor.execute(new CheckedRunnable() {
611 executor.execute(new CheckedRunnable() {
617 joinPool(executor);
ArrayBlockingQueueTest.java 748 * offer transfers elements across Executor tasks
754 ExecutorService executor = Executors.newFixedThreadPool(2); local
756 executor.execute(new CheckedRunnable() {
764 executor.execute(new CheckedRunnable() {
771 joinPool(executor);
775 * timed poll retrieves elements across Executor threads
780 ExecutorService executor = Executors.newFixedThreadPool(2); local
781 executor.execute(new CheckedRunnable() {
789 executor.execute(new CheckedRunnable() {
795 joinPool(executor);
    [all...]
LinkedTransferQueueTest.java 564 * offer transfers elements across Executor tasks
569 ExecutorService executor = Executors.newFixedThreadPool(2); local
571 executor.execute(new CheckedRunnable() {
577 executor.execute(new CheckedRunnable() {
584 joinPool(executor);
588 * timed poll retrieves elements across Executor threads
593 ExecutorService executor = Executors.newFixedThreadPool(2); local
595 executor.execute(new CheckedRunnable() {
603 executor.execute(new CheckedRunnable() {
609 joinPool(executor);
    [all...]
  /libcore/luni/src/test/java/libcore/java/net/
SocketTest.java 357 private ExecutorService executor; field in class:SocketTest.MockServer
362 executor = Executors.newCachedThreadPool();
370 return executor.submit(new Callable<byte[]>() {
390 executor.shutdown();
  /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/chromium_org/net/proxy/
multi_threaded_proxy_resolver.cc 25 // An "executor" is a job-runner for PAC requests. It encapsulates a worker
28 class MultiThreadedProxyResolver::Executor
29 : public base::RefCountedThreadSafe<MultiThreadedProxyResolver::Executor > {
32 // signal when the executor is ready to receive work by calling
36 Executor(MultiThreadedProxyResolver* coordinator,
40 // Submit a job to this executor.
43 // Callback for when a job has completed running on the executor's thread.
46 // Cleanup the executor. Cancels all outstanding work, and frees the thread
58 friend class base::RefCountedThreadSafe<Executor>;
59 ~Executor();
104 Executor* executor() { function in class:net::MultiThreadedProxyResolver::Job
411 Executor* executor = FindIdleExecutor(); local
492 Executor* executor = AddNewExecutor(); local
503 const Executor* executor = it->get(); local
519 Executor* executor = it->get(); local
530 Executor* executor = it->get(); local
544 Executor* executor = new Executor( local
    [all...]
  /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() {
  /external/chromium_org/third_party/skia/src/animator/
SkDisplayApply.cpp 117 SkDisplayable* executor = animator->hasExecute() ? animator : target; local
126 executor->executeFunction(target, info->functionIndex(), typedValues, info->getType(), NULL);
  /external/skia/src/animator/
SkDisplayApply.cpp 117 SkDisplayable* executor = animator->hasExecute() ? animator : target; local
126 executor->executeFunction(target, info->functionIndex(), typedValues, info->getType(), NULL);
  /packages/providers/DownloadProvider/src/com/android/providers/downloads/
DownloadService.java 120 final ThreadPoolExecutor executor = new ThreadPoolExecutor( local
144 executor.allowCoreThreadTimeOut(true);
145 return executor;
  /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
72 @Override protected ScheduledExecutorService executor() { return executor; } method in class:AbstractScheduledServiceTest.NullService
219 protected ScheduledExecutorService executor() { method in class:AbstractScheduledServiceTest.TestService
221 return executor;
367 @Override protected ScheduledExecutorService executor() { method in class:AbstractScheduledServiceTest.SchedulerTest.TestAbstractScheduledCustomService
413 @Override protected ScheduledExecutorService executor() { method in class:TestFailingCustomScheduledService
  /libcore/luni/src/test/java/libcore/javax/net/ssl/
SSLSocketTest.java 317 ExecutorService executor = Executors.newSingleThreadExecutor(); local
318 Future<Void> future = executor.submit(new Callable<Void>() {
338 executor.shutdown();
370 final ExecutorService executor = Executors.newSingleThreadExecutor(); local
375 final Future<byte[]> future1 = executor.submit(new SSLServerSessionIdCallable(server1));
388 final Future<byte[]> future2 = executor.submit(new SSLServerSessionIdCallable(server2));
400 executor.shutdown();
410 ExecutorService executor = Executors.newSingleThreadExecutor(); local
411 Future<Void> future = executor.submit(new Callable<Void>() {
421 executor.shutdown()
440 ExecutorService executor = Executors.newSingleThreadExecutor(); local
460 ExecutorService executor = Executors.newSingleThreadExecutor(); local
582 ExecutorService executor = Executors.newSingleThreadExecutor(); local
648 ExecutorService executor = Executors.newSingleThreadExecutor(); local
702 ExecutorService executor = Executors.newSingleThreadExecutor(); local
732 ExecutorService executor = Executors.newSingleThreadExecutor(); local
804 ExecutorService executor = Executors.newSingleThreadExecutor(); local
851 ExecutorService executor = Executors.newSingleThreadExecutor(); local
893 ExecutorService executor = Executors.newSingleThreadExecutor(); local
922 ExecutorService executor = Executors.newSingleThreadExecutor(); local
1122 ExecutorService executor = Executors.newSingleThreadExecutor(); local
1224 ExecutorService executor = Executors.newSingleThreadExecutor(); local
1277 ExecutorService executor = Executors.newSingleThreadExecutor(); local
1354 ExecutorService executor = Executors.newSingleThreadExecutor(); local
1394 ExecutorService executor = Executors.newSingleThreadExecutor(new ThreadFactory() { local
1585 ExecutorService executor = Executors.newFixedThreadPool(2); local
1623 ExecutorService executor = Executors.newFixedThreadPool(2); local
1661 ExecutorService executor = Executors.newFixedThreadPool(2); local
    [all...]
  /external/conscrypt/src/test/java/org/conscrypt/
NativeCryptoTest.java 938 ExecutorService executor = Executors.newSingleThreadExecutor(); local
    [all...]
  /prebuilts/eclipse/maven/apache-maven-3.2.1/lib/
aether-connector-wagon-0.9.0.M2.jar 
  /prebuilts/eclipse/mavenplugins/tycho/tycho-dependencies-m2repo/org/eclipse/tycho/tycho-bundles-external/0.20.0/eclipse/plugins/
org.eclipse.equinox.concurrent_1.1.0.v20130327-1442.jar 
org.eclipse.equinox.p2.jarprocessor_1.0.300.v20130327-2119.jar 
  /prebuilts/tools/common/m2/repository/org/eclipse/tycho/tycho-bundles-external/0.18.1/eclipse/plugins/
org.eclipse.equinox.concurrent_1.1.0.v20130327-1442.jar 
org.eclipse.equinox.p2.jarprocessor_1.0.300.v20130327-2119.jar 
  /external/eclipse-basebuilder/basebuilder-3.6.2/org.eclipse.releng.basebuilder/plugins/
org.eclipse.equinox.p2.jarprocessor_1.0.200.v20100503a.jar 
  /prebuilts/eclipse/mavenplugins/tycho/tycho-dependencies-m2repo/org/eclipse/tycho/sisu-equinox-launching/0.20.0/
sisu-equinox-launching-0.20.0.jar 

Completed in 1501 milliseconds

1 23 4 5 6 7