Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 261 - 270 of 505 for Sleeps (0.04 seconds)

  1. android/guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java

        final int millis;
        volatile boolean completed;
    
        SleepingRunnable(int millis) {
          this.millis = millis;
        }
    
        @Override
        public void run() {
          try {
            Thread.sleep(millis);
          } catch (InterruptedException wontHappen) {
            throw new AssertionError();
          }
          completed = true;
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 8.9K bytes
    - Click Count (0)
  2. guava-testlib/src/com/google/common/collect/testing/testers/ListAddAtIndexTester.java

      }
    
      @ListFeature.Require(absent = SUPPORTS_ADD_WITH_INDEX)
      @CollectionSize.Require(absent = ZERO)
      /*
       * absent = ZERO isn't required, since unmodList.add() must
       * throw regardless, but it keeps the method name accurate.
       */
      public void testAddAtIndex_unsupportedPresent() {
        assertThrows(UnsupportedOperationException.class, () -> getList().add(0, e0()));
        expectUnchanged();
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 5.5K bytes
    - Click Count (0)
  3. src/test/java/jcifs/internal/smb1/com/SmbComNTCreateAndXTest.java

            assertTrue(str.contains("securityFlags=0x03"), "securityFlags should be present");
        }
    
        /**
         * Fetch a private field value via reflection.  This helper keeps the
         * test code tidy and is used where unit‑testing logic relies on
         * internally stored data.
         */
        private static Object getPrivateField(Object target, String name) {
            try {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 5.6K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

        override fun writeTo(sink: BufferedSink) {
          try {
            var i = 0
            while (i < contentLength()) {
              sink.write(chunk!!)
              sink.flush()
              Thread.sleep(100)
              i += chunk.size
            }
          } catch (e: IOException) {
            ioe = e
          } catch (e: InterruptedException) {
            throw RuntimeException(e)
          }
        }
      }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 70.7K bytes
    - Click Count (0)
  5. fastapi/.agents/skills/fastapi/SKILL.md

    ---
    name: fastapi
    description: FastAPI best practices and conventions. Use when working with FastAPI APIs and Pydantic models for them. Keeps FastAPI code clean and up to date with the latest features and patterns, updated with new versions. Write new code or refactor and update old code.
    ---
    
    # FastAPI
    
    Official FastAPI skill to write code with best practices, keeping up to date with new versions and features.
    
    ## Use the `fastapi` CLI
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sun Mar 01 10:05:57 GMT 2026
    - 10.1K bytes
    - Click Count (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        while (!isThreadBlockedOnInstanceOf(t, blocker)) {
          if (t.getState() == Thread.State.TERMINATED) {
            throw new RuntimeException("Thread " + t + " exited unexpectedly");
          }
          Thread.sleep(1);
        }
      }
    
      private static boolean isThreadBlockedOnInstanceOf(Thread t, Class<?> blocker) {
        return t.getState() == Thread.State.WAITING && blocker.isInstance(LockSupport.getBlocker(t));
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.2K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        while (!isThreadBlockedOnInstanceOf(t, blocker)) {
          if (t.getState() == Thread.State.TERMINATED) {
            throw new RuntimeException("Thread " + t + " exited unexpectedly");
          }
          Thread.sleep(1);
        }
      }
    
      private static boolean isThreadBlockedOnInstanceOf(Thread t, Class<?> blocker) {
        return t.getState() == Thread.State.WAITING && blocker.isInstance(LockSupport.getBlocker(t));
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.2K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/helper/WebFsIndexHelper.java

                        crawlerStatusList.set(startedCrawlerNum, Constants.RUNNING);
                        startedCrawlerNum++;
                        activeCrawlerNum++;
                        ThreadUtil.sleep(crawlingExecutionInterval);
                        continue;
                    }
    
                    // check status
                    for (int i = 0; i < startedCrawlerNum; i++) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 25K bytes
    - Click Count (0)
  9. helm-releases/minio-4.0.10.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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 04 16:09:22 GMT 2022
    - 19.2K bytes
    - Click Count (0)
  10. helm-releases/minio-4.0.14.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 Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Sep 05 01:06:49 GMT 2022
    - 19.6K bytes
    - Click Count (0)
Back to Top