Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 191 - 200 of 890 for thread (0.1 seconds)

  1. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnsh/builtin/BuiltinShellCommandRegistryFactory.java

                        builder.directory(shellContext.cwd.get().toFile());
                        Process process = builder.start();
                        Thread out = new Thread(new StreamGobbler(process.getInputStream(), shellContext.writer));
                        Thread err = new Thread(new StreamGobbler(process.getErrorStream(), shellContext.logger::error));
                        out.start();
                        err.start();
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Sat Jun 07 06:22:47 GMT 2025
    - 12.3K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/cache/LoadingCache.java

     * instances is using {@link CacheBuilder}.
     *
     * <p>Implementations of this interface are expected to be thread-safe, and can be safely accessed
     * by multiple concurrent threads.
     *
     * <p>When evaluated as a {@link Function}, a cache yields the same result as invoking {@link
     * #getUnchecked}.
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 03 12:40:22 GMT 2026
    - 8.5K bytes
    - Click Count (0)
  3. guava/src/com/google/common/cache/Cache.java

     * evicted or manually invalidated. The common way to build instances is using {@link CacheBuilder}.
     *
     * <p>Implementations of this interface are expected to be thread-safe, and can be safely accessed
     * by multiple concurrent threads.
     *
     * @param <K> the type of the cache's keys, which are not permitted to be null
     * @param <V> the type of the cache's values, which are not permitted to be null
     * @author Charles Fry
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 03 12:40:22 GMT 2026
    - 8K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/util/concurrent/AtomicDoubleArrayTest.java

            prev = x;
          }
        }
      }
    
      /** compareAndSet in one thread enables another waiting for value to succeed */
      public void testCompareAndSetInMultipleThreads() throws InterruptedException {
        AtomicDoubleArray a = new AtomicDoubleArray(1);
        a.set(0, 1.0);
        Thread t =
            newStartedThread(
                new CheckedRunnable() {
                  @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 14.8K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java

        Thread thread =
            new Thread() {
              @Override
              public void run() {
                try {
                  cacheRef.get().getUnchecked(3);
                } finally {
                  doneSignal.countDown();
                }
              }
            };
        thread.setUncaughtExceptionHandler((t, throwable) -> {});
        thread.start();
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 13.1K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java

        Thread thread =
            new Thread() {
              @Override
              public void run() {
                try {
                  cacheRef.get().getUnchecked(3);
                } finally {
                  doneSignal.countDown();
                }
              }
            };
        thread.setUncaughtExceptionHandler((t, throwable) -> {});
        thread.start();
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 13.1K bytes
    - Click Count (0)
  7. src/test/java/jcifs/smb1/smb1/TestLockingTest.java

                        t.url = args[ai];
                    }
                }
    
                assertEquals(expectedUrl, t.url, "URL should be correctly parsed");
                assertEquals(2, t.numThreads, "Thread count should be parsed");
                assertEquals(5, t.numIter, "Iteration count should be parsed");
                assertEquals(100L, t.delay, "Delay should be parsed");
            }
    
            @Test
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 9.9K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/SimpleTimeLimiter.java

      }
    
      /**
       * Creates a TimeLimiter instance using the given executor service to execute method calls.
       *
       * <p><b>Warning:</b> using a bounded executor may be counterproductive! If the thread pool fills
       * up, any time callers spend waiting for a thread may count toward their time limit, and in this
       * case the call may even time out before the target method is ever invoked.
       *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 08 18:35:13 GMT 2025
    - 9.6K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

     * example involving two locks and two threads, deadlock occurs when one thread acquires Lock A, and
     * then Lock B, while another thread acquires Lock B, and then Lock A:
     *
     * <pre>
     * Thread1: acquire(LockA) --X acquire(LockB)
     * Thread2: acquire(LockB) --X acquire(LockA)
     * </pre>
     *
     * <p>Neither thread will progress because each is waiting for the other. In more complex
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 36K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/util/concurrent/AtomicDoubleTest.java

          assertBitEquals(x, at.get());
          prev = x;
        }
      }
    
      /** compareAndSet in one thread enables another waiting for value to succeed */
      public void testCompareAndSetInMultipleThreads() throws Exception {
        AtomicDouble at = new AtomicDouble(1.0);
        Thread t =
            newStartedThread(
                new CheckedRunnable() {
                  @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 10.6K bytes
    - Click Count (0)
Back to Top