Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for newSingleThreadExecutor (0.39 sec)

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

    import static com.google.common.util.concurrent.testing.TestingExecutors.noOpScheduledExecutor;
    import static java.util.Arrays.asList;
    import static java.util.concurrent.Executors.newSingleThreadExecutor;
    import static java.util.concurrent.Executors.newSingleThreadScheduledExecutor;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static java.util.concurrent.TimeUnit.NANOSECONDS;
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 144.5K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

    import static com.google.common.util.concurrent.testing.TestingExecutors.noOpScheduledExecutor;
    import static java.util.Arrays.asList;
    import static java.util.concurrent.Executors.newSingleThreadExecutor;
    import static java.util.concurrent.Executors.newSingleThreadScheduledExecutor;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static java.util.concurrent.TimeUnit.NANOSECONDS;
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 144.5K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

                  failures.add(failure);
                }
              });
    
      final ListeningExecutorService executor =
          MoreExecutors.listeningDecorator(newSingleThreadExecutor());
      final ExecutorService closingExecutor = newSingleThreadExecutor();
    
      final TestCloseable closeable1 = new TestCloseable("closeable1");
      final TestCloseable closeable2 = new TestCloseable("closeable2");
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 74.7K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

                  failures.add(failure);
                }
              });
    
      final ListeningExecutorService executor =
          MoreExecutors.listeningDecorator(newSingleThreadExecutor());
      final ExecutorService closingExecutor = newSingleThreadExecutor();
    
      final TestCloseable closeable1 = new TestCloseable("closeable1");
      final TestCloseable closeable2 = new TestCloseable("closeable2");
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 75.3K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/io/MoreFilesTest.java

            Path dirToDelete = fs.getPath("dir/b/i");
            Path changingFile = dirToDelete.resolve("j/l");
            Path symlinkTarget = fs.getPath("/dontdelete");
    
            ExecutorService executor = Executors.newSingleThreadExecutor();
            startDirectorySymlinkSwitching(changingFile, symlinkTarget, executor);
    
            try {
              for (int i = 0; i < iterations; i++) {
                try {
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Mon Jan 29 22:57:05 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/cache/LocalCacheTest.java

    import static com.google.common.truth.Truth.assertThat;
    import static com.google.common.util.concurrent.MoreExecutors.listeningDecorator;
    import static java.lang.Thread.State.WAITING;
    import static java.util.concurrent.Executors.newSingleThreadExecutor;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static java.util.concurrent.TimeUnit.MINUTES;
    import static java.util.concurrent.TimeUnit.NANOSECONDS;
    import static java.util.concurrent.TimeUnit.SECONDS;
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Thu Mar 14 23:06:48 GMT 2024
    - 112.3K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

    import static com.google.common.truth.Truth.assertThat;
    import static com.google.common.util.concurrent.MoreExecutors.listeningDecorator;
    import static java.lang.Thread.State.WAITING;
    import static java.util.concurrent.Executors.newSingleThreadExecutor;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static java.util.concurrent.TimeUnit.MINUTES;
    import static java.util.concurrent.TimeUnit.NANOSECONDS;
    import static java.util.concurrent.TimeUnit.SECONDS;
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Mar 14 23:06:48 GMT 2024
    - 110.7K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

       * despite not throwing a RejectedExecutionException synchronously with the call to {@code
       * execute}. If this behaviour is problematic, use an Executor with a single thread (e.g. {@link
       * Executors#newSingleThreadExecutor}).
       *
       * @since 23.3 (since 23.1 as {@code sequentialExecutor})
       */
      @J2ktIncompatible
      @GwtIncompatible
      public static Executor newSequentialExecutor(Executor delegate) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 17 16:33:44 GMT 2024
    - 41.8K bytes
    - Viewed (0)
Back to top