Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 501 for Runnable (0.12 seconds)

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

       * otherwise-concurrent GC cycle.
       */
      private static final class TaskNonReentrantExecutor extends AtomicReference<RunningState>
          implements Executor, Runnable {
    
        /**
         * Used to update and read the latestTaskQueue field. Set to null once the runnable has been run
         * or queued.
         */
        @Nullable ExecutionSequencer sequencer;
    
        /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 23 01:35:55 GMT 2025
    - 22.1K bytes
    - Click Count (0)
  2. 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();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/mylasta/direction/sponsor/FessMailDeliveryDepartmentCreator.java

        //                                                                        ============
        protected void async(final AsyncManager asyncManager, final Runnable runnable) {
            asyncManager.async(new ConcurrentAsyncCall() {
                @Override
                public void callback() {
                    runnable.run();
                }
    
                @Override
                public boolean asPrimary() {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 7K bytes
    - Click Count (0)
  4. android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

      }
    
      @Override
      public <T> ListenableFuture<T> submit(Runnable task, T result) {
        Preconditions.checkNotNull(task, "task must not be null!");
        Preconditions.checkNotNull(result, "result must not be null!");
        return delegate.submit(task, result);
      }
    
      @Override
      public ListenableFuture<?> submit(Runnable task) {
        Preconditions.checkNotNull(task, "task must not be null!");
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:37:28 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  5. guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

      }
    
      @Override
      public <T> ListenableFuture<T> submit(Runnable task, T result) {
        Preconditions.checkNotNull(task, "task must not be null!");
        Preconditions.checkNotNull(result, "result must not be null!");
        return delegate.submit(task, result);
      }
    
      @Override
      public ListenableFuture<?> submit(Runnable task) {
        Preconditions.checkNotNull(task, "task must not be null!");
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:37:28 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  6. src/main/java/jcifs/util/SimpleCircuitBreaker.java

                throw e;
            }
        }
    
        /**
         * Execute a runnable through the circuit breaker
         *
         * @param runnable the runnable to execute
         * @throws Exception if execution fails or circuit is open
         */
        public void run(Runnable runnable) throws Exception {
            call(() -> {
                runnable.run();
                return null;
            });
        }
    
        /**
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 11.3K bytes
    - Click Count (0)
  7. 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
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  8. android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java

      }
    
      public void testSameThreadScheduledExecutorWithException() throws InterruptedException {
        Runnable runnable =
            () -> {
              throw new RuntimeException("Oh no!");
            };
    
        Future<?> future = TestingExecutors.sameThreadScheduledExecutor().submit(runnable);
        assertThrows(ExecutionException.class, future::get);
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 3.3K bytes
    - Click Count (0)
  9. guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java

      }
    
      public void testSameThreadScheduledExecutorWithException() throws InterruptedException {
        Runnable runnable =
            () -> {
              throw new RuntimeException("Oh no!");
            };
    
        Future<?> future = TestingExecutors.sameThreadScheduledExecutor().submit(runnable);
        assertThrows(ExecutionException.class, future::get);
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 3.3K bytes
    - Click Count (0)
  10. android/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) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 45.6K bytes
    - Click Count (0)
Back to Top