Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 334 for executors (0.08 sec)

  1. 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);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  2. guava/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);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  3. android/guava/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);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  4. docs/pt/docs/fastapi-cli.md

    O servidor de desenvolvimento escutará no endereço de IP `127.0.0.1` por padrão, este é o IP que sua máquina usa para se comunicar com ela mesma (`localhost`).
    
    ## `fastapi run`
    
    Quando você rodar `fastapi run`, isso executará em modo de produção por padrão.
    
    Este modo terá **recarregamento automático desativado** por padrão.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/DispatcherTest.kt

        dispatcher.maxRequestsPerHost = 4
        executor.assertJobs("http://a/1", "http://a/2", "http://a/3", "http://a/4")
      }
    
      @Test
      fun oldJobFinishesNewJobCanRunDifferentHost() {
        dispatcher.maxRequests = 1
        client.newCall(newRequest("http://a/1")).enqueue(callback)
        client.newCall(newRequest("http://b/1")).enqueue(callback)
        executor.finishJob("http://a/1")
        executor.assertJobs("http://b/1")
      }
    
      @Test
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Fri Apr 05 03:30:42 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/FluentFuture.java

       *     returned future.
       * @param executor Executor to run the function in.
       * @return A future that holds result of the transformation.
       */
      public final <T extends @Nullable Object> FluentFuture<T> transform(
          Function<? super V, T> function, Executor executor) {
        return (FluentFuture<T>) Futures.transform(this, function, executor);
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  7. docs/contribute/concurrency.md

    Sometimes there's an action required like calling the application layer or responding to a ping, and the thread discovering the action is not the thread that should do the work. We enqueue a runnable on this executor and it gets handled by one of the executor's threads.
    
    ### Locks
    
    We have 3 different things that we synchronize on.
    
    #### Http2Connection
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

          if (activeTask == null && futureTasks.isEmpty()) {
            return CountDownLatch(0)
          }
    
          // If there's an existing AwaitIdleTask, use it. This is necessary when the executor is
          // shutdown but still busy as we can't enqueue in that case.
          val existingTask = activeTask
          if (existingTask is AwaitIdleTask) {
            return existingTask.latch
          }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  9. 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) {}
                };
              }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  10. 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
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (0)
Back to top