Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 191 - 200 of 568 for sleeps (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. .github/workflows/test.yml

                coverage: coverage
                codspeed: codspeed
              - os: ubuntu-latest
                python-version: "3.14"
                coverage: coverage
          fail-fast: false
        runs-on: ${{ matrix.os }}
        steps:
          - name: Dump GitHub context
            env:
              GITHUB_CONTEXT: ${{ toJson(github) }}
            run: echo "$GITHUB_CONTEXT"
          - uses: actions/checkout@v6
          - name: Set up Python
    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)
  3. 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)
  4. 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)
  5. samples/guide/src/main/java/okhttp3/recipes/PostStreamingWithPipe.java

            try {
              sink.writeUtf8("Numbers\n");
              sink.writeUtf8("-------\n");
              for (int i = 2; i <= 997; i++) {
                System.out.println(i);
                Thread.sleep(10);
                sink.writeUtf8(String.format(" * %s = %s\n", i, factor(i)));
              }
              sink.close();
            } catch (IOException | InterruptedException e) {
              e.printStackTrace();
            }
    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)
  6. 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)
  7. 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)
  8. .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=true
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Tue Dec 09 22:14:16 GMT 2025
    - 2.1K bytes
    - Click Count (0)
  9. 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)
  10. 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)
Back to Top