Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 171 - 180 of 470 for executors (0.06 seconds)

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

      }
    
      public void testTimeout() throws Exception {
        // Create a service whose executor will never run its commands
        Service service =
            new TestService() {
              @Override
              protected Executor executor() {
                return new Executor() {
                  @Override
                  public void execute(Runnable command) {}
                };
              }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 7.7K bytes
    - Click Count (0)
  2. android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java

      }
    
      public void testNoOpScheduledExecutorShutdown() {
        ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor();
        assertFalse(executor.isShutdown());
        assertFalse(executor.isTerminated());
        executor.shutdown();
        assertTrue(executor.isShutdown());
        assertTrue(executor.isTerminated());
      }
    
    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)
  3. guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java

      }
    
      public void testNoOpScheduledExecutorShutdown() {
        ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor();
        assertFalse(executor.isShutdown());
        assertFalse(executor.isTerminated());
        executor.shutdown();
        assertTrue(executor.isShutdown());
        assertTrue(executor.isTerminated());
      }
    
    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)
  4. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

       *
       * @param listener the listener to run when the computation is complete
       * @param executor the executor to run the listener in
       * @throws RejectedExecutionException if we tried to execute the listener immediately but the
       *     executor rejected it.
       */
      void addListener(Runnable listener, Executor executor);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 22:14:05 GMT 2026
    - 8K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/DispatcherTest.kt

        c1.enqueue(callback)
        c2.enqueue(callback)
        c1.cancel()
        executor.assertJobs("http://a/1")
        executor.finishJob("http://a/1")
        executor.assertJobs("http://a/2")
      }
    
      @Test
      fun asyncCallAccessors() {
        dispatcher.maxRequests = 3
        val a1 = client.newCall(newRequest("http://a/1"))
        val a2 = client.newCall(newRequest("http://a/2"))
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  6. docs/pt/docs/environment-variables.md

    O sistema **encontrará** o programa `python` em `/opt/custompython/bin` e o executará.
    
    Seria aproximadamente equivalente a digitar:
    
    <div class="termy">
    
    ```console
    $ /opt/custompython/bin/python
    ```
    
    </div>
    
    ////
    
    //// tab | Windows
    
    O sistema **encontrará** o programa `python` em `C:\opt\custompython\bin\python` e o executará.
    
    Seria aproximadamente equivalente a digitar:
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:20:43 GMT 2026
    - 8.4K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

       */
      public <T extends @Nullable Object> ListenableFuture<T> submitAsync(
          AsyncCallable<T> callable, Executor executor) {
        checkNotNull(callable);
        checkNotNull(executor);
        TaskNonReentrantExecutor taskExecutor = new TaskNonReentrantExecutor(executor, this);
        AsyncCallable<T> task =
            new AsyncCallable<T>() {
              @Override
    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)
  8. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

        // null only for TOMBSTONE
        final @Nullable Executor executor;
    
        // writes to next are made visible by subsequent CAS's on the listeners field
        @Nullable Listener next;
    
        Listener(Runnable task, Executor executor) {
          this.task = task;
          this.executor = executor;
        }
    
        Listener() {
          this.task = null;
          this.executor = null;
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 14:39:00 GMT 2026
    - 43.6K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/cache/CacheLoaderTest.java

        assertThat(loadCount.get()).isEqualTo(1);
        assertThat(reloadCount.get()).isEqualTo(1);
        assertThat(loadAllCount.get()).isEqualTo(1);
    
        QueuingExecutor executor = new QueuingExecutor();
        CacheLoader<Object, Object> asyncReloader = CacheLoader.asyncReloading(baseLoader, executor);
    
        Object unused3 = asyncReloader.load(new Object());
        @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 30 22:03:28 GMT 2025
    - 3.8K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/eventbus/Subscriber.java

      private final Method method;
    
      /** Executor to use for dispatching events to this subscriber. */
      private final Executor executor;
    
      private Subscriber(EventBus bus, Object target, Method method) {
        this.bus = bus;
        this.target = checkNotNull(target);
        this.method = method;
        method.setAccessible(true);
    
        this.executor = bus.executor();
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed May 14 19:40:47 GMT 2025
    - 4.7K bytes
    - Click Count (0)
Back to Top