Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for AbstractListeningExecutorService (0.19 sec)

  1. guava/src/com/google/common/util/concurrent/AbstractListeningExecutorService.java

     * termination.
     *
     * @author Chris Povirk
     * @since 14.0
     */
    @CheckReturnValue
    @GwtIncompatible
    public abstract class AbstractListeningExecutorService extends AbstractExecutorService
        implements ListeningExecutorService {
      /** Constructor for use by subclasses. */
      public AbstractListeningExecutorService() {}
    
      /**
       * @since 19.0 (present with return type {@code ListenableFutureTask} since 14.0)
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 12 17:47:46 UTC 2025
    - 3K bytes
    - Viewed (0)
  2. guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.collect.ImmutableList;
    import com.google.common.util.concurrent.AbstractFuture;
    import com.google.common.util.concurrent.AbstractListeningExecutorService;
    import com.google.common.util.concurrent.ListenableScheduledFuture;
    import com.google.common.util.concurrent.ListeningScheduledExecutorService;
    import com.google.common.util.concurrent.MoreExecutors;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java

    import java.util.List;
    import java.util.concurrent.Callable;
    import java.util.concurrent.TimeUnit;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Tests for {@link AbstractListeningExecutorService}.
     *
     * @author Colin Decker
     */
    @NullUnmarked
    public class AbstractListeningExecutorServiceTest extends TestCase {
    
      public void testSubmit() throws Exception {
        /*
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java

    import java.util.List;
    import java.util.concurrent.Callable;
    import java.util.concurrent.TimeUnit;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Tests for {@link AbstractListeningExecutorService}.
     *
     * @author Colin Decker
     */
    @NullUnmarked
    public class AbstractListeningExecutorServiceTest extends TestCase {
    
      public void testSubmit() throws Exception {
        /*
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/DirectExecutorService.java

    import java.util.concurrent.TimeUnit;
    
    /** See newDirectExecutorService javadoc for behavioral notes. */
    @J2ktIncompatible // Emulated
    @GwtIncompatible
    final class DirectExecutorService extends AbstractListeningExecutorService {
    
      /** Lock used whenever accessing the state variables (runningTasks, shutdown) of the executor */
      private final Object lock = new Object();
    
      /*
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Apr 12 15:07:59 UTC 2025
    - 3.5K bytes
    - Viewed (0)
  6. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.collect.ImmutableList;
    import com.google.common.util.concurrent.AbstractFuture;
    import com.google.common.util.concurrent.AbstractListeningExecutorService;
    import com.google.common.util.concurrent.ListenableScheduledFuture;
    import com.google.common.util.concurrent.ListeningScheduledExecutorService;
    import com.google.common.util.concurrent.MoreExecutors;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/DirectExecutorService.java

    import java.util.concurrent.TimeUnit;
    
    /** See newDirectExecutorService javadoc for behavioral notes. */
    @J2ktIncompatible // Emulated
    @GwtIncompatible
    final class DirectExecutorService extends AbstractListeningExecutorService {
    
      /** Lock used whenever accessing the state variables (runningTasks, shutdown) of the executor */
      private final Object lock = new Object();
    
      /*
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Apr 12 15:07:59 UTC 2025
    - 3.5K bytes
    - Viewed (0)
Back to top