OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
defs:scheduledExecutorService
(Results
1 - 15
of
15
) sorted by null
/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
InProcessServerBuilder.java
32
import java.util.concurrent.
ScheduledExecutorService
;
95
private ObjectPool<
ScheduledExecutorService
> schedulerPool =
119
public InProcessServerBuilder
scheduledExecutorService
(
120
ScheduledExecutorService
scheduledExecutorService
) {
121
schedulerPool = new FixedObjectPool<
ScheduledExecutorService
>(
122
checkNotNull(
scheduledExecutorService
, "
scheduledExecutorService
"));
InProcessChannelBuilder.java
29
import java.util.concurrent.
ScheduledExecutorService
;
69
private
ScheduledExecutorService
scheduledExecutorService
;
141
public InProcessChannelBuilder
scheduledExecutorService
(
142
ScheduledExecutorService
scheduledExecutorService
) {
143
this.
scheduledExecutorService
=
144
checkNotNull(
scheduledExecutorService
, "
scheduledExecutorService
");
151
return new InProcessClientTransportFactory(name,
scheduledExecutorService
);
[
all
...]
/external/grpc-grpc-java/core/src/test/java/io/grpc/inprocess/
InProcessChannelBuilderTest.java
25
import java.util.concurrent.
ScheduledExecutorService
;
51
ScheduledExecutorService
scheduledExecutorService
=
54
InProcessChannelBuilder builder1 = builder.
scheduledExecutorService
(
scheduledExecutorService
);
59
assertSame(
scheduledExecutorService
, clientTransportFactory.getScheduledExecutorService());
InProcessServerBuilderTest.java
30
import java.util.concurrent.
ScheduledExecutorService
;
59
ObjectPool<
ScheduledExecutorService
> scheduledExecutorServicePool =
61
ObjectPool<
ScheduledExecutorService
> expectedPool =
64
ScheduledExecutorService
expected = expectedPool.getObject();
65
ScheduledExecutorService
actual = scheduledExecutorServicePool.getObject();
75
ScheduledExecutorService
scheduledExecutorService
=
78
InProcessServerBuilder builder1 = builder.
scheduledExecutorService
(
scheduledExecutorService
);
82
ObjectPool<
ScheduledExecutorService
> scheduledExecutorServicePool
[
all
...]
/external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/
CronetChannelBuilderTest.java
34
import java.util.concurrent.
ScheduledExecutorService
;
100
ScheduledExecutorService
scheduledExecutorService
= mock(
ScheduledExecutorService
.class);
102
CronetChannelBuilder builder1 = builder.
scheduledExecutorService
(
scheduledExecutorService
);
106
assertSame(
scheduledExecutorService
, clientTransportFactory.getScheduledExecutorService());
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
OkHttpChannelBuilderTest.java
32
import java.util.concurrent.
ScheduledExecutorService
;
152
ScheduledExecutorService
scheduledExecutorService
=
155
OkHttpChannelBuilder builder1 = builder.
scheduledExecutorService
(
scheduledExecutorService
);
160
assertSame(
scheduledExecutorService
, clientTransportFactory.getScheduledExecutorService());
/external/grpc-grpc-java/android/src/main/java/io/grpc/android/
AndroidChannelBuilder.java
41
import java.util.concurrent.
ScheduledExecutorService
;
150
* Set the delegate channel builder's
scheduledExecutorService
.
156
public AndroidChannelBuilder
scheduledExecutorService
(
157
ScheduledExecutorService
scheduledExecutorService
) {
160
.getMethod("
scheduledExecutorService
",
ScheduledExecutorService
.class)
161
.invoke(delegateBuilder,
scheduledExecutorService
);
165
"Failed to invoke
scheduledExecutorService
on delegate builder", e);
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
FakeClock.java
30
import java.util.concurrent.
ScheduledExecutorService
;
35
* A manipulated clock that exports a {@link Ticker} and a {@link
ScheduledExecutorService
}.
51
private final
ScheduledExecutorService
scheduledExecutorService
= new ScheduledExecutorImpl();
111
private class ScheduledExecutorImpl implements
ScheduledExecutorService
{
190
* Provides a partially implemented instance of {@link
ScheduledExecutorService
} that uses the
193
public
ScheduledExecutorService
getScheduledExecutorService() {
194
return
scheduledExecutorService
;
FakeClockTest.java
25
import java.util.concurrent.
ScheduledExecutorService
;
40
ScheduledExecutorService
scheduledExecutorService1 = fakeClock.getScheduledExecutorService();
41
ScheduledExecutorService
scheduledExecutorService2 = fakeClock.getScheduledExecutorService();
130
ScheduledExecutorService
scheduledExecutorService
= fakeClock.getScheduledExecutorService();
132
scheduledExecutorService
.schedule(newRunnable(), 200L, TimeUnit.NANOSECONDS);
133
scheduledExecutorService
.execute(newRunnable());
134
scheduledExecutorService
.schedule(newRunnable(), 0L, TimeUnit.NANOSECONDS);
135
scheduledExecutorService
.schedule(newRunnable(), 80L, TimeUnit.NANOSECONDS);
136
scheduledExecutorService
.schedule(newRunnable(), 90L, TimeUnit.NANOSECONDS)
[
all
...]
/external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/
CronetChannelBuilder.java
39
import java.util.concurrent.
ScheduledExecutorService
;
78
private
ScheduledExecutorService
scheduledExecutorService
;
178
public final CronetChannelBuilder
scheduledExecutorService
(
179
ScheduledExecutorService
scheduledExecutorService
) {
180
this.
scheduledExecutorService
=
181
checkNotNull(
scheduledExecutorService
, "
scheduledExecutorService
");
191
scheduledExecutorService
,
[
all
...]
/external/grpc-grpc-java/android/src/test/java/io/grpc/android/
AndroidChannelBuilderTest.java
41
import java.util.concurrent.
ScheduledExecutorService
;
120
public void
scheduledExecutorService
() {
121
AndroidChannelBuilder.forTarget("target").
scheduledExecutorService
(new ScheduledExecutorImpl());
415
private static class ScheduledExecutorImpl implements
ScheduledExecutorService
{
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
OkHttpChannelBuilder.java
51
import java.util.concurrent.
ScheduledExecutorService
;
152
private
ScheduledExecutorService
scheduledExecutorService
;
388
public final OkHttpChannelBuilder
scheduledExecutorService
(
389
ScheduledExecutorService
scheduledExecutorService
) {
390
this.
scheduledExecutorService
=
391
checkNotNull(
scheduledExecutorService
, "
scheduledExecutorService
");
399
return new OkHttpTransportFactory(transportExecutor,
scheduledExecutorService
,
[
all
...]
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
RetriableStream.java
41
import java.util.concurrent.
ScheduledExecutorService
;
64
private final
ScheduledExecutorService
scheduledExecutorService
;
100
Executor callExecutor,
ScheduledExecutorService
scheduledExecutorService
,
108
this.
scheduledExecutorService
=
scheduledExecutorService
;
597
scheduledRetry =
scheduledExecutorService
.schedule(
/external/grpc-grpc-java/core/
grpc-core-1.14.0.jar
/external/mockito/lib/
byte-buddy-1.8.15.jar
Completed in 527 milliseconds