- Sort Score
- Num 10 results
- Language All
Results 191 - 200 of 568 for sleeps (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/namespace-lock_test.go
} // lk2 lk2ch := make(chan struct{}) go func() { defer close(lk2ch) nsLk.lock(ctx, "volume", "path", "source", "opsID", false, 1*time.Millisecond) }() time.Sleep(1 * time.Millisecond) // wait for goroutine to advance; ref=2 // Unlock the 1st lock; ref=1 after this line nsLk.unlock("volume", "path", false)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 3K bytes - Click Count (0) -
.github/workflows/test.yml
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Fri Dec 26 08:53:59 GMT 2025 - 4.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
thread.start(); thread.awaitWaiting(); Thread.class.getMethod("suspend").invoke(thread); // Sleep for enough time to add 1500 milliseconds of overwait to the get() call. long toWaitMillis = 3500 - NANOSECONDS.toMillis(System.nanoTime() - thread.startTime); Thread.sleep(toWaitMillis); thread.setPriority(Thread.MAX_PRIORITY); Thread.class.getMethod("resume").invoke(thread); thread.join();
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 20:45:32 GMT 2025 - 46.8K bytes - Click Count (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/gcs/GcsClientTest.java
setupGcsClient(bucketName, endpoint); break; } catch (final Exception e) { logger.warn("[{}] {}", i + 1, e.getMessage()); } ThreadUtil.sleep(1000L); } } private void setupGcsClient(String bucketName, String endpoint) throws Exception { Storage storage = StorageOptions.newBuilder()// .setProjectId(PROJECT_ID)//
Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Thu Dec 11 08:38:29 GMT 2025 - 19.6K bytes - Click Count (0) -
samples/guide/src/main/java/okhttp3/recipes/PostStreamingWithPipe.java
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Jul 06 03:18:15 GMT 2018 - 3.1K bytes - Click Count (0) -
android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
public void run() { taskDone = true; } }; ScheduledFuture<?> future = TestingExecutors.noOpScheduledExecutor().schedule(task, 10, MILLISECONDS); Thread.sleep(20); assertFalse(taskDone); assertFalse(future.isDone()); } public void testNoOpScheduledExecutorShutdown() { ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor();
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Oct 18 22:10:29 GMT 2024 - 3.7K bytes - Click Count (0) -
guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
public void run() { taskDone = true; } }; ScheduledFuture<?> future = TestingExecutors.noOpScheduledExecutor().schedule(task, 10, MILLISECONDS); Thread.sleep(20); assertFalse(taskDone); assertFalse(future.isDone()); } public void testNoOpScheduledExecutorShutdown() { ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor();
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Oct 18 22:10:29 GMT 2024 - 3.7K bytes - Click Count (0) -
.github/workflows/update-jdks.yml
in:building-gradle @dev-productivity - name: Trigger a build uses: peter-evans/create-or-update-comment@v5 if: ${{ steps.create-pull-request.outputs.pull-request-number }} with: issue-number: ${{ steps.create-pull-request.outputs.pull-request-number }} body: | @bot-gradle test ReadyForNightly ``` stopGradleDaemons=trueCreated: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Tue Dec 09 22:14:16 GMT 2025 - 2.1K bytes - Click Count (0) -
guava-testlib/src/com/google/common/collect/testing/ListIteratorTester.java
* * <p>The items in {@code elementsToInsert} will be repeated if {@code steps} is larger than the * number of provided elements. * * @author Chris Povirk */ @GwtCompatible @NullMarked public abstract class ListIteratorTester<E extends @Nullable Object> extends AbstractIteratorTester<E, ListIterator<E>> { protected ListIteratorTester( int steps, Iterable<E> elementsToInsert,Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 2.3K bytes - Click Count (0) -
helm-releases/minio-1.0.0.tgz
in the event of a failed command. {{- if .Values.configPathmc }} MC_CONFIG_DIR="{{ .Values.configPathmc }}" MC="/usr/bin/mc --insecure --config-dir ${MC_CONFIG_DIR}" {{- else }} MC="/usr/bin/mc --insecure" {{- end }} # connectToMinio # Use a check-sleep-check loop to wait for Minio service to be available connectToMinio() { SCHEME=$1 ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts set -e ; # fail if we can't read the keys. ACCESS=$(cat /config/rootUser) ; SECRET=$(cat /config/rootPassword) ; set +e ;...Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 20 22:30:54 GMT 2021 - 13.5K bytes - Click Count (0)