Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 47 for threads (0.25 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

      /**
       * When we need a new thread to run tasks, we call [Backend.execute]. A few microseconds later we
       * expect a newly-started thread to call [Runnable.run]. We shouldn't request new threads until
       * the already-requested ones are in service, otherwise we might create more threads than we need.
       *
       * We use [executeCallCount] and [runCallCount] to defend against starting more threads than we
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  2. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

     * deterministic.
     *
     * This class ensures that at most one thread is running at a time. This is initially the JUnit test
     * thread, which yields its execution privilege while calling [runTasks], [runNextTask], or
     * [advanceUntil]. These functions don't return until the task threads are all idle.
     *
     * Task threads release their execution privilege in these ways:
     *
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 12.6K bytes
    - Viewed (0)
  3. maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java

        private final Executor executor;
    
        public DefaultArtifactResolver() {
            int threads = Integer.getInteger("maven.artifact.threads", 5);
            if (threads <= 1) {
                executor = Runnable::run;
            } else {
                executor = new ThreadPoolExecutor(
                        threads, threads, 3, TimeUnit.SECONDS, new LinkedBlockingQueue<>(), new DaemonThreadCreator());
            }
        }
    
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Thu Apr 25 05:46:50 GMT 2024
    - 24.8K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt

        assertThat(realTaskRunner.activeQueues()).isNotEmpty()
        Thread.sleep(100)
        val threads = arrayOfNulls<Thread>(Thread.activeCount() * 2)
        Thread.enumerate(threads)
        for (t in threads) {
          if (t != null && t.name == "OkHttp TaskRunner") {
            t.interrupt()
          }
        }
        Thread.sleep(100)
        assertThat(realTaskRunner.activeQueues()).isEmpty()
      }
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 24 04:40:49 GMT 2024
    - 12.7K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

          // unpark even though the thread has already removed itself from the list. But even if we did
          // use a CAS, that race would still exist (it would just be ever so slightly smaller).
          Thread w = thread;
          if (w != null) {
            thread = null;
            LockSupport.unpark(w);
          }
        }
      }
    
      /**
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 22 21:17:24 GMT 2024
    - 63K bytes
    - Viewed (0)
  6. cni/README.md

    - Set: `values.global.logging.level="cni:debug,ambient:debug"`
    - Inspect the pod logs of a `istio-cni` Daemonset pod on a specific node.
    
    #### From a specific node syslog
    
    The CNI plugins are executed by threads in the `kubelet` process.  The CNI plugins logs end up the syslog
    under the `kubelet` process. On systems with `journalctl` the following is an example command line
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 12.3K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

       * one from the pool. We must take the pooled connection because by taking it from the pool, we've
       * fully acquired it.
       *
       * This test yields threads to force the decision of plan1 to be deliberate and not lucky. In
       * particular, we set up this sequence of events:
       *
       *  1. take plan 0
       *  3. plan 0 connects
       *  4. finish taking plan 1
       *
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 24 04:40:49 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/Ordering.java

          Integer uid = uids.get(obj);
          if (uid == null) {
            // One or more integer values could be skipped in the event of a race
            // to generate a UID for the same object from multiple threads, but
            // that shouldn't be a problem.
            uid = counter.getAndIncrement();
            Integer alreadySet = uids.putIfAbsent(obj, uid);
            if (alreadySet != null) {
              uid = alreadySet;
            }
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Apr 24 19:38:27 GMT 2024
    - 39.4K bytes
    - Viewed (0)
  9. RELEASE.md

        of TensorFlow.
    *   Deprecated the use of `constraint=` and `.constraint` with ResourceVariable.
    *   `tf.keras`:
        *   `OMP_NUM_THREADS` is no longer used by the default Keras config. To
            configure the number of threads, use `tf.config.threading` APIs.
        *   `tf.keras.model.save_model` and `model.save` now defaults to saving a
            TensorFlow SavedModel.
    Plain Text
    - Registered: Tue May 07 12:40:20 GMT 2024
    - Last Modified: Mon Apr 29 19:17:57 GMT 2024
    - 727.7K bytes
    - Viewed (8)
  10. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

        checkNotNull(runnable, "Runnable was null.");
        checkNotNull(executor, "Executor was null.");
    
        // Lock while we check state. We must maintain the lock while adding the new pair so that
        // another thread can't run the list out from under us. We only add to the list if we have not
        // yet started execution.
        synchronized (this) {
          if (!executed) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 22 21:17:24 GMT 2024
    - 6.9K bytes
    - Viewed (0)
Back to top