Lines Matching refs:service
20 import com.google.common.util.concurrent.Service.State;
60 NullService service = new NullService();
61 service.startAsync().awaitRunning();
63 service.stopAsync().awaitTerminated();
74 TestService service = new TestService();
75 service.runException = new Exception();
76 service.startAsync().awaitRunning();
77 service.runFirstBarrier.await();
78 service.runSecondBarrier.await();
85 assertEquals(service.runException, e.getCause().getCause());
87 assertEquals(service.state(), Service.State.FAILED);
91 TestService service = new TestService();
92 service.startUpException = new Exception();
94 service.startAsync().awaitRunning();
97 assertEquals(service.startUpException, e.getCause());
99 assertEquals(0, service.numberOfTimesRunCalled.get());
100 assertEquals(Service.State.FAILED, service.state());
104 TestService service = new TestService();
105 service.shutDownException = new Exception();
106 service.startAsync().awaitRunning();
107 service.runFirstBarrier.await();
108 service.stopAsync();
109 service.runSecondBarrier.await();
111 service.awaitTerminated();
114 assertEquals(service.shutDownException, e.getCause());
116 assertEquals(Service.State.FAILED, service.state());
120 TestService service = new TestService();
121 service.startAsync().awaitRunning();
123 service.runFirstBarrier.await();
124 assertEquals(i, service.numberOfTimesRunCalled.get());
125 service.runSecondBarrier.await();
127 service.runFirstBarrier.await();
128 service.stopAsync();
129 service.runSecondBarrier.await();
130 service.stopAsync().awaitTerminated();
134 TestService service = new TestService();
135 service.startAsync().awaitRunning();
137 assertEquals(1, service.numberOfTimesExecutorCalled.get());
139 service.runFirstBarrier.await();
140 assertEquals(i, service.numberOfTimesRunCalled.get());
141 service.runSecondBarrier.await();
143 service.runFirstBarrier.await();
144 service.stopAsync();
145 service.runSecondBarrier.await();
146 service.stopAsync().awaitTerminated();
148 assertEquals(1, service.numberOfTimesExecutorCalled.get());
153 AbstractScheduledService service = new AbstractScheduledService() {
166 service.startAsync();
167 assertFalse(service.executor().isShutdown());
168 service.awaitRunning();
169 service.stopAsync();
170 service.awaitTerminated();
176 AbstractScheduledService service = new AbstractScheduledService() {
194 service.startAsync().awaitRunning();
195 fail("Expected service to fail during startup");
202 TestService service = new TestService();
203 service.startAsync().awaitRunning();
205 assertEquals(1, service.numberOfTimesSchedulerCalled.get());
207 service.runFirstBarrier.await();
208 assertEquals(i, service.numberOfTimesRunCalled.get());
209 service.runSecondBarrier.await();
211 service.runFirstBarrier.await();
212 service.stopAsync();
213 service.runSecondBarrier.await();
214 service.awaitTerminated();
216 assertEquals(1, service.numberOfTimesSchedulerCalled.get());
364 TestAbstractScheduledCustomService service = new TestAbstractScheduledCustomService();
365 service.startAsync().awaitRunning();
366 service.firstBarrier.await();
367 assertEquals(1, service.numIterations.get());
368 service.stopAsync();
369 service.secondBarrier.await();
370 service.awaitTerminated();
373 assertEquals(1, service.numIterations.get());
377 TestAbstractScheduledCustomService service = new TestAbstractScheduledCustomService() {
389 service.useBarriers = false;
390 service.startAsync().awaitRunning();
392 service.useBarriers = true;
393 service.firstBarrier.await();
394 int numIterations = service.numIterations.get();
395 service.stopAsync();
396 service.secondBarrier.await();
397 service.awaitTerminated();
398 assertEquals(numIterations, service.numIterations.get());
434 TestFailingCustomScheduledService service = new TestFailingCustomScheduledService();
435 service.startAsync().awaitRunning();
437 service.firstBarrier.await();
438 assertEquals(i, service.numIterations.get());
439 service.secondBarrier.await();
443 service.stopAsync().awaitTerminated(100, TimeUnit.SECONDS);
446 assertEquals(State.FAILED, service.state());
