Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for newDirectExecutorService (0.68 sec)

  1. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        }
      }
    
      public void testDirectExecutorService_shutdownNow() {
        ExecutorService executor = newDirectExecutorService();
        assertEquals(ImmutableList.of(), executor.shutdownNow());
        assertTrue(executor.isShutdown());
      }
    
      public void testExecuteAfterShutdown() {
        ExecutorService executor = newDirectExecutorService();
        executor.shutdown();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 28K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/DirectExecutorService.java

    import com.google.errorprone.annotations.concurrent.GuardedBy;
    import java.util.List;
    import java.util.concurrent.RejectedExecutionException;
    import java.util.concurrent.TimeUnit;
    
    /** See newDirectExecutorService javadoc for behavioral notes. */
    @J2ktIncompatible // Emulated
    @GwtIncompatible
    final class DirectExecutorService extends AbstractListeningExecutorService {
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Apr 12 15:07:59 UTC 2025
    - 3.5K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/CallablesTest.java

     * limitations under the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertThat;
    import static com.google.common.util.concurrent.MoreExecutors.newDirectExecutorService;
    import static com.google.common.util.concurrent.ReflectionFreeAssertThrows.assertThrows;
    
    import com.google.common.annotations.GwtCompatible;
    import com.google.common.annotations.GwtIncompatible;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  4. android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

     * limitations under the License.
     */
    
    package com.google.common.util.concurrent.testing;
    
    import static com.google.common.util.concurrent.MoreExecutors.newDirectExecutorService;
    import static java.util.concurrent.Executors.callable;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.base.Preconditions;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:37:28 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  5. guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

     * limitations under the License.
     */
    
    package com.google.common.util.concurrent.testing;
    
    import static com.google.common.util.concurrent.MoreExecutors.newDirectExecutorService;
    import static java.util.concurrent.Executors.callable;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.base.Preconditions;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:37:28 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/DirectExecutorService.java

    import com.google.errorprone.annotations.concurrent.GuardedBy;
    import java.util.List;
    import java.util.concurrent.RejectedExecutionException;
    import java.util.concurrent.TimeUnit;
    
    /** See newDirectExecutorService javadoc for behavioral notes. */
    @J2ktIncompatible // Emulated
    @GwtIncompatible
    final class DirectExecutorService extends AbstractListeningExecutorService {
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Apr 12 15:07:59 UTC 2025
    - 3.5K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertThat;
    import static com.google.common.util.concurrent.MoreExecutors.newDirectExecutorService;
    import static com.google.common.util.concurrent.Runnables.doNothing;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static java.util.concurrent.TimeUnit.SECONDS;
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  8. guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

       * (unless the executor has been shutdown).
       *
       * <p>The returned executor is backed by the executor returned by {@link
       * MoreExecutors#newDirectExecutorService} and subject to the same constraints.
       *
       * <p>Although all tasks are immediately executed in the thread that submitted the task, this
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  9. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

       * (unless the executor has been shutdown).
       *
       * <p>The returned executor is backed by the executor returned by {@link
       * MoreExecutors#newDirectExecutorService} and subject to the same constraints.
       *
       * <p>Although all tasks are immediately executed in the thread that submitted the task, this
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 6.6K bytes
    - Viewed (0)
Back to top