Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 247 for runnable (0.1 sec)

  1. guava-tests/test/com/google/common/reflect/ReflectionTest.java

        assertEquals("java.util", Reflection.getPackageName(Map.Entry.class));
      }
    
      public void testNewProxy() throws Exception {
        Runnable runnable = Reflection.newProxy(Runnable.class, X_RETURNER);
        assertEquals("x", runnable.toString());
      }
    
      public void testNewProxyCantWorkOnAClass() throws Exception {
        assertThrows(
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/MoreExecutors.java

       */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      static Thread newThread(String name, Runnable runnable) {
        checkNotNull(name);
        checkNotNull(runnable);
        // TODO(b/139726489): Confirm that null is impossible here.
        Thread result = requireNonNull(platformThreadFactory().newThread(runnable));
        try {
          result.setName(name);
        } catch (SecurityException e) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 08 18:55:33 UTC 2025
    - 45.2K bytes
    - Viewed (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

      val taskRunner: TaskRunner =
        TaskRunner(
          object : TaskRunner.Backend {
            override fun execute(
              taskRunner: TaskRunner,
              runnable: Runnable,
            ) {
              taskRunner.assertLockHeld()
    
              val queuedTask = RunnableSerialTask(runnable)
              serialTaskQueue += queuedTask
              executeCallCount++
              isParallel = serialTaskQueue.size > 1
            }
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 11.9K bytes
    - Viewed (0)
  4. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  5. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

          return true;
        }
    
        @Override
        public void execute(Runnable runnable) {}
    
        @Override
        public <V> ListenableScheduledFuture<V> schedule(
            Callable<V> callable, long delay, TimeUnit unit) {
          return NeverScheduledFuture.create();
        }
    
        @Override
        public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
          return NeverScheduledFuture.create();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  6. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Feb 11 17:30:04 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java

        inBetween.assertRun();
        after.assertRun();
      }
    
      public void testMisbehavingListenerAlreadyDone() {
        class BadRunnableException extends RuntimeException {}
    
        Runnable bad =
            new Runnable() {
              @Override
              public void run() {
                throw new BadRunnableException();
              }
            };
    
        future.set(1);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 15.4K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/reflect/AbstractInvocationHandlerTest.java

            .addEqualityGroup(newDelegatingList(LIST2))
            .addEqualityGroup(
                newProxyWithEqualsForInterfaces(List.class, Runnable.class),
                newProxyWithEqualsForInterfaces(List.class, Runnable.class))
            .addEqualityGroup(newProxyWithEqualsForInterfaces(Runnable.class, List.class))
            .addEqualityGroup(
                newDelegatingListWithEquals(LIST1),
                newDelegatingListWithEquals(LIST1),
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Dec 28 02:48:50 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/WrappingScheduledExecutorService.java

      }
    
      @Override
      public final ScheduledFuture<?> scheduleAtFixedRate(
          Runnable command, long initialDelay, long period, TimeUnit unit) {
        return delegate.scheduleAtFixedRate(wrapTask(command), initialDelay, period, unit);
      }
    
      @Override
      public final ScheduledFuture<?> scheduleWithFixedDelay(
          Runnable command, long initialDelay, long delay, TimeUnit unit) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

                    public Integer call() {
                      return counter.incrementAndGet();
                    }
                  });
          CyclicBarrier barrier = new CyclicBarrier(numThreads + 1);
          Runnable wrapper =
              new Runnable() {
                @Override
                public void run() {
                  awaitUnchecked(barrier);
                  task.run();
                  awaitUnchecked(barrier);
                }
              };
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 7.2K bytes
    - Viewed (0)
Back to top