OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:ExecutorService
(Results
1 - 25
of
75
) sorted by null
1
2
3
/frameworks/base/core/java/android/app/
QueuedWork.java
20
import java.util.concurrent.
ExecutorService
;
41
private static
ExecutorService
sSingleThreadExecutor = null; // lazy, guarded by class
47
public static
ExecutorService
singleThreadExecutor() {
/packages/apps/Browser/src/com/android/browser/
BackgroundHandler.java
21
import java.util.concurrent.
ExecutorService
;
27
static
ExecutorService
mThreadPool;
/external/guava/guava-tests/test/com/google/common/util/concurrent/
AbstractListeningExecutorServiceTest.java
27
import java.util.concurrent.
ExecutorService
;
58
ExecutorService
e = new DirectExecutorService();
70
ExecutorService
e = new DirectExecutorService();
80
ExecutorService
e = new DirectExecutorService();
90
ExecutorService
e = new DirectExecutorService();
103
ExecutorService
e = new DirectExecutorService();
126
ExecutorService
e = new DirectExecutorService();
146
ExecutorService
e = new DirectExecutorService();
169
ExecutorService
e = new DirectExecutorService();
180
ExecutorService
e = new DirectExecutorService()
[
all
...]
ListenableFutureTester.java
27
import java.util.concurrent.
ExecutorService
;
38
private final
ExecutorService
exec;
ListenableFutureTaskTest.java
24
import java.util.concurrent.
ExecutorService
;
35
private
ExecutorService
exec;
/external/guava/guava/src/com/google/common/util/concurrent/
ListeningExecutorService.java
22
import java.util.concurrent.
ExecutorService
;
28
* An {@link
ExecutorService
} that returns {@link ListenableFuture} instances. To create an instance
29
* from an existing {@link
ExecutorService
}, call
30
* {@link MoreExecutors#listeningDecorator(
ExecutorService
)}.
35
public interface ListeningExecutorService extends
ExecutorService
{
ListenableFuture.java
20
import java.util.concurrent.
ExecutorService
;
63
* <li>If they are returned from an {@code
ExecutorService
}, convert that
65
* MoreExecutors#listeningDecorator(
ExecutorService
)
MoreExecutors.java
26
import java.util.concurrent.
ExecutorService
;
42
*
ExecutorService
}, and {@link ThreadFactory}.
53
* Converts the given ThreadPoolExecutor into an
ExecutorService
that exits
68
public static
ExecutorService
getExitingExecutorService(
75
ExecutorService
service = Executors.unconfigurableExecutorService(executor);
117
* {@link
ExecutorService
service}. This is useful if the given service uses
121
* @param service
ExecutorService
which uses daemon threads
128
final
ExecutorService
service, final long terminationTimeout,
149
* Converts the given ThreadPoolExecutor into an
ExecutorService
that exits
164
public static
ExecutorService
getExitingExecutorService
[
all
...]
ForwardingExecutorService.java
25
import java.util.concurrent.
ExecutorService
;
40
implements
ExecutorService
{
45
protected abstract
ExecutorService
delegate();
SimpleTimeLimiter.java
33
import java.util.concurrent.
ExecutorService
;
41
* {@link
ExecutorService
}. If the time limit expires for a given method call,
50
private final
ExecutorService
executor;
62
* @param executor the
ExecutorService
that will execute the method calls on
66
public SimpleTimeLimiter(
ExecutorService
executor) {
/external/jmonkeyengine/engine/src/core/com/jme3/asset/
ThreadingManager.java
36
import java.util.concurrent.
ExecutorService
;
48
protected final
ExecutorService
executor =
/cts/libs/vogar-expect/src/vogar/util/
Threads.java
19
import java.util.concurrent.
ExecutorService
;
42
public static
ExecutorService
threadPerCpuExecutor(String name) {
46
public static
ExecutorService
fixedThreadsExecutor(String name, int count) {
/libcore/luni/src/main/java/java/util/concurrent/
ScheduledExecutorService.java
12
* An {@link
ExecutorService
} that can schedule commands to run after a given
22
* {@link
ExecutorService
} <tt>submit</tt> methods are scheduled with
67
public interface ScheduledExecutorService extends
ExecutorService
{
Executors.java
20
*
ExecutorService
}, {@link ScheduledExecutorService}, {@link
25
* <li> Methods that create and return an {@link
ExecutorService
}
29
* <li> Methods that create and return a "wrapped"
ExecutorService
, that
53
* until it is explicitly {@link
ExecutorService
#shutdown shutdown}.
59
public static
ExecutorService
newFixedThreadPool(int nThreads) {
75
* exist until it is explicitly {@link
ExecutorService
#shutdown
84
public static
ExecutorService
newFixedThreadPool(int nThreads, ThreadFactory threadFactory) {
104
public static
ExecutorService
newSingleThreadExecutor() {
125
public static
ExecutorService
newSingleThreadExecutor(ThreadFactory threadFactory) {
149
public static
ExecutorService
newCachedThreadPool()
[
all
...]
/packages/apps/Contacts/src/com/android/contacts/vcard/
ProcessorBase.java
18
import java.util.concurrent.
ExecutorService
;
25
* vCard or exports a vCard). Expected to be used with {@link
ExecutorService
}.
/external/guava/guava-tests/test/com/google/common/testing/
FakeTickerTest.java
26
import java.util.concurrent.
ExecutorService
;
53
ExecutorService
executorService
= Executors.newFixedThreadPool(numberOfThreads);
57
executorService
.submit(new Callable<Void>() {
/packages/providers/CalendarProvider/src/com/android/providers/calendar/
CalendarReceiver.java
26
import java.util.concurrent.
ExecutorService
;
40
private final
ExecutorService
executor = Executors.newCachedThreadPool();
/sdk/hierarchyviewer2/app/src/com/android/hierarchyviewer/
HierarchyViewerApplicationDirector.java
23
import java.util.concurrent.
ExecutorService
;
31
private final
ExecutorService
mExecutor = Executors.newSingleThreadExecutor();
/external/junit/src/org/junit/experimental/
ParallelComputer.java
6
import java.util.concurrent.
ExecutorService
;
40
private final
ExecutorService
fService= Executors
/libcore/luni/src/test/java/tests/security/
SecureRandomTest.java
23
import java.util.concurrent.
ExecutorService
;
79
ExecutorService
executor = Executors.newFixedThreadPool(threads);
/external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/
AbstractListenableFutureTest.java
27
import java.util.concurrent.
ExecutorService
;
167
ExecutorService
exec = Executors.newCachedThreadPool();
212
ExecutorService
exec = Executors.newCachedThreadPool();
/libcore/support/src/test/java/tests/support/
Support_Exec.java
31
import java.util.concurrent.
ExecutorService
;
85
ExecutorService
executorService
= Executors.newFixedThreadPool(2);
87
Future<String> errFuture =
executorService
.submit(
89
Future<String> outFuture =
executorService
.submit(
113
executorService
.shutdown();
125
ExecutorService
executorService
= Executors.newFixedThreadPool(2);
128
executorService
.submit(streamToStringCallable(process.getErrorStream()));
130
executorService
.submit(streamToStringCallable(process.getInputStream()))
[
all
...]
/libcore/luni/src/test/java/libcore/java/util/zip/
DeflaterOutputStreamTest.java
29
import java.util.concurrent.
ExecutorService
;
69
ExecutorService
executor = Executors.newSingleThreadExecutor();
/libcore/support/src/test/java/libcore/javax/net/ssl/
TestSSLSocketPair.java
21
import java.util.concurrent.
ExecutorService
;
79
ExecutorService
executor = Executors.newFixedThreadPool(2);
/external/guava/guava-bootstrap/src/java/util/concurrent/
ExecutorService.java
3
* http://gee.cs.oswego.edu/cgi-bin/viewcvs.cgi/jsr166/src/main/java/util/concurrent/
ExecutorService
.java?revision=1.51
16
public interface
ExecutorService
extends Executor {
Completed in 3669 milliseconds
1
2
3