Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 27 of 27 for services (0.15 sec)

  1. guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

       */
      public static ListeningScheduledExecutorService noOpScheduledExecutor() {
        return new NoOpScheduledExecutorService();
      }
    
      /**
       * Creates a scheduled executor service that runs each task in the thread that invokes {@code
       * execute/submit/schedule}, as in {@link CallerRunsPolicy}. This applies both to individually
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Fri May 26 22:04:00 GMT 2023
    - 6.7K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java

        assertEquals(1, service.startUpCalled);
        assertEquals(Service.State.FAILED, service.state());
        assertThat(service.transitionStates).containsExactly(Service.State.STARTING);
      }
    
      public void testStop_withoutStart() {
        TestService service = new TestService();
        service.stopAsync().awaitTerminated();
        assertEquals(0, service.startUpCalled);
        assertEquals(0, service.shutDownCalled);
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 7.5K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java

      public void testEnqueueAndDispatch_multithreaded() throws InterruptedException {
        Object listener = new Object();
        ExecutorService service = Executors.newFixedThreadPool(4);
        ListenerCallQueue<Object> queue = new ListenerCallQueue<>();
        try {
          queue.addListener(listener, service);
    
          final CountDownLatch latch = new CountDownLatch(1);
          Multiset<Object> counters = ConcurrentHashMultiset.create();
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 8.2K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java

     * {@code ExecutorService}. Most users should call {@link ListeningExecutorService#submit(Callable)
     * ListeningExecutorService.submit} on a service obtained from {@link
     * MoreExecutors#listeningDecorator}.
     *
     * @author Sven Mawson
     * @since 1.0
     */
    @J2ktIncompatible
    @GwtIncompatible
    @ElementTypesAreNonnullByDefault
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 4.3K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AtomicDouble.java

    @ElementTypesAreNonnullByDefault
    public class AtomicDouble extends Number implements java.io.Serializable {
      private static final long serialVersionUID = 0L;
    
      // We would use AtomicLongFieldUpdater, but it has issues on some Android devices.
      private transient AtomicLong value;
    
      /**
       * Creates a new {@code AtomicDouble} with the given initial value.
       *
       * @param initialValue the initial value
       */
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Feb 28 21:00:54 GMT 2022
    - 7.2K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/graph/ImmutableValueGraph.java

       *         .addNode(REYKJAVIK)
       *         .build();
       * }</pre>
       *
       * <p>Builder instances can be reused; it is safe to call {@link #build} multiple times to build
       * multiple graphs in series. Each new graph contains all the elements of the ones created before
       * it.
       *
       * @since 28.0
       */
      public static class Builder<N, V> {
    
        private final MutableValueGraph<N, V> mutableValueGraph;
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Feb 01 16:30:37 GMT 2022
    - 7.7K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ForwardingListeningExecutorService.java

    import java.util.concurrent.Callable;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * A listening executor service which forwards all its method calls to another listening executor
     * service. Subclasses should override one or more methods to modify the behavior of the backing
     * executor service as desired per the <a
     * href="http://en.wikipedia.org/wiki/Decorator_pattern">decorator pattern</a>.
     *
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 2.2K bytes
    - Viewed (0)
Back to top