Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 464 for Runnable (0.05 sec)

  1. android/guava/src/com/google/common/util/concurrent/Callables.java

              boolean unused = trySetName(oldName, currentThread);
            }
          }
        };
      }
    
      /**
       * Wraps the given runnable such that for the duration of {@link Runnable#run} the thread that is
       * running with have the given name.
       *
       * @param task The Runnable to wrap
       * @param nameSupplier The supplier of thread names, {@link Supplier#get get} will be called once
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/AbstractListeningExecutorService.java

       */
      @CanIgnoreReturnValue // TODO(kak): consider removing this
      @Override
      protected final <T extends @Nullable Object> RunnableFuture<T> newTaskFor(
          Runnable runnable, @ParametricNullness T value) {
        return TrustedListenableFutureTask.create(runnable, value);
      }
    
      /**
       * @since 19.0 (present with return type {@code ListenableFutureTask} since 14.0)
       */
      @CanIgnoreReturnValue // TODO(kak): consider removing this
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 3K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/AbstractListeningExecutorService.java

       */
      @CanIgnoreReturnValue // TODO(kak): consider removing this
      @Override
      protected final <T extends @Nullable Object> RunnableFuture<T> newTaskFor(
          Runnable runnable, @ParametricNullness T value) {
        return TrustedListenableFutureTask.create(runnable, value);
      }
    
      /**
       * @since 19.0 (present with return type {@code ListenableFutureTask} since 14.0)
       */
      @CanIgnoreReturnValue // TODO(kak): consider removing this
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 3K bytes
    - Viewed (0)
  4. src/test/java/jcifs/tests/ConcurrencyTest.java

            List<MutiThreadTestCase> runnables = new ArrayList<>();
            for ( int i = 0; i < 20; i++ ) {
                runnables.add(new MutiThreadTestCase());
            }
            runMultiTestCase(runnables, 60);
        }
    
    
        private void runMultiTestCase ( List<? extends MultiTestCase> testcases, int timeoutSecs ) throws InterruptedException {
            for ( Runnable r : testcases ) {
                this.executor.submit(r);
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 14 17:40:50 UTC 2021
    - 17.6K bytes
    - Viewed (0)
  5. build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/AnonymousClassesFilteringTest.kt

                        public void some() {}
                    }
                """,
                v2 = """
                    public class Source {
                        public void some() {
                            Runnable anon = new Runnable() {
                                @Override
                                public void run() {}
                            };
                            anon.run();
                        }
                    }
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Dec 09 08:14:05 UTC 2020
    - 1.8K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/FakeTimeLimiter.java

      }
    
      @Override
      @SuppressWarnings("CatchingUnchecked") // sneaky checked exception
      public void runWithTimeout(Runnable runnable, long timeoutDuration, TimeUnit timeoutUnit) {
        checkNotNull(runnable);
        checkNotNull(timeoutUnit);
        try {
          runnable.run();
        } catch (Exception e) { // sneaky checked exception
          throw new UncheckedExecutionException(e);
        } catch (Error e) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java

      }
    
      @Override
      public void shutdown() {
        delegate().shutdown();
      }
    
      @Override
      @CanIgnoreReturnValue
      public List<Runnable> shutdownNow() {
        return delegate().shutdownNow();
      }
    
      @Override
      public void execute(Runnable command) {
        delegate().execute(command);
      }
    
      @Override
      public <T extends @Nullable Object> Future<T> submit(Callable<T> task) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/ListeningScheduledExecutorService.java

      @Override
      ListenableScheduledFuture<?> scheduleAtFixedRate(
          Runnable command, long initialDelay, long period, TimeUnit unit);
    
      /** @since 15.0 (previously returned ScheduledFuture) */
      @Override
      ListenableScheduledFuture<?> scheduleWithFixedDelay(
          Runnable command, long initialDelay, long delay, TimeUnit unit);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  9. android/guava-testlib/src/com/google/common/collect/testing/google/ReflectionFreeAssertThrows.java

      }
    
      @CanIgnoreReturnValue
      static <T extends Throwable> T assertThrows(
          Class<T> expectedThrowable, ThrowingRunnable runnable) {
        return doAssertThrows(
            expectedThrowable,
            () -> {
              runnable.run();
              return null;
            },
            /* userPassedSupplier= */ false);
      }
    
      private static <T extends Throwable> T doAssertThrows(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 19:10:20 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  10. guava-testlib/test/com/google/common/testing/ReflectionFreeAssertThrows.java

      }
    
      @CanIgnoreReturnValue
      static <T extends Throwable> T assertThrows(
          Class<T> expectedThrowable, ThrowingRunnable runnable) {
        return doAssertThrows(
            expectedThrowable,
            () -> {
              runnable.run();
              return null;
            },
            /* userPassedSupplier= */ false);
      }
    
      private static <T extends Throwable> T doAssertThrows(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 22 13:49:09 UTC 2024
    - 6.3K bytes
    - Viewed (0)
Back to top