Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 322 for tasks (0.02 sec)

  1. guava/src/com/google/common/util/concurrent/DirectExecutorService.java

       *
       * @throws RejectedExecutionException if the executor has been previously shutdown
       */
      private void startTask() {
        synchronized (lock) {
          if (shutdown) {
            throw new RejectedExecutionException("Executor already shutdown");
          }
          runningTasks++;
        }
      }
    
      /** Decrements the running task count. */
      private void endTask() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Apr 12 15:07:59 UTC 2025
    - 3.5K bytes
    - Viewed (0)
  2. .teamcity/src/main/kotlin/common/PerformanceTestExtensions.kt

        }
    }
    
    fun performanceTestCommandLine(
        task: String,
        baselines: String,
        extraParameters: String = "",
        os: Os = Os.LINUX,
        arch: Arch = Arch.AMD64,
        testJavaVersion: String = os.perfTestJavaVersion.major.toString(),
        testJavaVendor: String = os.perfTestJavaVendor.name.lowercase(),
    ) = listOf(
        "$task${if (extraParameters.isEmpty()) "" else " $extraParameters"}",
    Registered: Wed Sep 10 11:36:15 UTC 2025
    - Last Modified: Mon Aug 25 20:21:47 UTC 2025
    - 4K bytes
    - Viewed (0)
  3. docs/pt/docs/advanced/async-tests.md

    /// tip | Dica
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Nov 18 02:25:44 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  4. guava/src/com/google/common/cache/CacheLoader.java

          }
    
          @Override
          public ListenableFuture<V> reload(K key, V oldValue) {
            ListenableFutureTask<V> task =
                ListenableFutureTask.create(() -> loader.reload(key, oldValue).get());
            executor.execute(task);
            return task;
          }
    
          @Override
          public Map<K, V> loadAll(Iterable<? extends K> keys) throws Exception {
            return loader.loadAll(keys);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 9.5K bytes
    - Viewed (0)
  5. docs/es/docs/advanced/async-tests.md

    /// tip | Consejo
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Dec 30 18:26:57 UTC 2024
    - 4K bytes
    - Viewed (0)
  6. docs/em/docs/advanced/async-tests.md

    πŸ”¬ πŸ”’ πŸ”œ πŸ”, πŸ‘† πŸ’ͺ πŸ”œ πŸ€™ (&amp; `await`) 🎏 `async` πŸ”’ ↖️ βšͺ️➑️ πŸ“¨ πŸ“¨ πŸ‘† FastAPI 🈸 πŸ‘† πŸ’―, βš«οΈβ” πŸ‘† πŸ”œ πŸ€™ πŸ‘« πŸ™† πŸ™† πŸ‘† πŸ“Ÿ.
    
    /// tip
    
    πŸš₯ πŸ‘† βš” `RuntimeError: Task attached to a different loop` πŸ•β” πŸ› οΈ πŸ” πŸ”’ πŸ€™ πŸ‘† πŸ’― (βœ… πŸ•β” βš™οΈ <a href="https://stackoverflow.com/questions/41584243/runtimeerror-task-attached-to-a-different-loop" class="external-link" target="_blank">✳ MotorClient</a>) πŸ’­ πŸ”— 🎚 πŸ‘ˆ πŸ’ͺ πŸŽ‰ ➰ πŸ•΄ 🏞 πŸ” πŸ”’, βœ… `'@app.on_event("startup")` ⏲.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Nov 18 02:25:44 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  7. docs/ko/docs/advanced/async-tests.md

    /// tip | 팁
    
    ν…ŒμŠ€νŠΈμ— 비동기 ν•¨μˆ˜ ν˜ΈμΆœμ„ 톡합할 λ•Œ (예: <a href="https://stackoverflow.com/questions/41584243/runtimeerror-task-attached-to-a-different-loop" class="external-link" target="_blank">MongoDB의 MotorClient</a>λ₯Ό μ‚¬μš©ν•  λ•Œ) `RuntimeError: Task attached to a different loop` 였λ₯˜κ°€ λ°œμƒν•œλ‹€λ©΄, 이벀트 루프가 ν•„μš”ν•œ κ°μ²΄λŠ” λ°˜λ“œμ‹œ 비동기 ν•¨μˆ˜ λ‚΄μ—μ„œλ§Œ μΈμŠ€ν„΄μŠ€ν™”ν•΄μ•Ό ν•œλ‹€λŠ” 점을 μ£Όμ˜ν•˜μ„Έμš”!
    예λ₯Ό λ“€μ–΄ `@app.on_event("startup")` 콜백 λ‚΄μ—μ„œ μΈμŠ€ν„΄μŠ€ν™”ν•˜λŠ” 것이 μ’‹μŠ΅λ‹ˆλ‹€.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Tue Dec 10 11:03:16 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  8. src/main/java/jcifs/util/ResourceManager.java

            return String.format("%s-%d-%d", resource.getClass().getSimpleName(), System.identityHashCode(resource),
                    resourceIdCounter.incrementAndGet());
        }
    
        /**
         * Start the cleanup task
         */
        private void startCleanupTask() {
            if (cleanupTask != null) {
                cleanupTask.cancel(false);
            }
    
            cleanupTask = cleanupExecutor.scheduleWithFixedDelay(() -> {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/curl/CurlRequest.java

                    if (connection != null) {
                        connection.disconnect();
                    }
                }
            };
            if (threadPool != null) {
                threadPool.execute(task);
            } else {
                task.run();
            }
        }
    
        /**
         * Opens a connection to the specified URL.
         *
         * @param u the URL
         * @return the HttpURLConnection
    Registered: Thu Sep 04 15:34:10 UTC 2025
    - Last Modified: Sat Jul 05 01:38:18 UTC 2025
    - 17.8K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java

      private final ExecutionList executionList = new ExecutionList();
    
      /**
       * Creates a {@code ListenableFutureTask} that will upon running, execute the given {@code
       * Callable}.
       *
       * @param callable the callable task
       * @since 10.0
       */
      public static <V extends @Nullable Object> ListenableFutureTask<V> create(Callable<V> callable) {
        return new ListenableFutureTask<>(callable);
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.2K bytes
    - Viewed (0)
Back to top