Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 517 for bgwait (0.05 sec)

  1. guava-testlib/test/com/google/common/testing/FakeTickerTest.java

                      startLatch.countDown();
                      startLatch.await();
                      callable.call();
                      doneLatch.countDown();
                      return null;
                    }
                  });
        }
        doneLatch.await();
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 6.3K bytes
    - Viewed (0)
  2. docs/em/docs/advanced/events.md

    ```Python
    with open("file.txt") as file:
        file.read()
    ```
    
    âŽī¸ âŦ 🐍, 📤 **🔁 🔑 👨‍đŸ’ŧ**. 👆 🔜 âš™ī¸ âšĢī¸ âŽī¸ `async with`:
    
    ```Python
    async with lifespan(app):
        await do_stuff()
    ```
    
    🕐❔ 👆 ✍ 🔑 👨‍đŸ’ŧ âš–ī¸ 🔁 🔑 👨‍đŸ’ŧ 💖 🔛, âšĢī¸â” âšĢī¸ 🔨 👈, ⏭ đŸ›Ŧ `with` đŸĢ, âšĢī¸ 🔜 đŸ› ī¸ 📟 ⏭ `yield`, & âŽī¸ ❎ `with` đŸĢ, âšĢī¸ 🔜 đŸ› ī¸ 📟 âŽī¸ `yield`.
    
    👆 📟 đŸ–ŧ 🔛, đŸ‘Ĩ đŸšĢ âš™ī¸ âšĢī¸ 🔗, âœ‹ī¸ đŸ‘Ĩ đŸšļâ€â™€ī¸ âšĢī¸ FastAPI âšĢī¸ âš™ī¸ âšĢī¸.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Nov 18 02:25:44 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. cmd/erasure.go

    				w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    				return w.Run(func() error {
    					wait := deleteCleanupSleeper.Timer(ctx)
    					removeAll(pathJoin(drivePath, minioMetaTmpDeletedBucket, ddir))
    					wait()
    					return nil
    				})
    			})
    		}(disk)
    	}
    	wg.Wait()
    }
    
    // nsScanner will start scanning buckets and send updated totals as they are traversed.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  4. docs/ko/docs/tutorial/request-files.md

    * `seek(offset)`: 파ėŧ 내 `offset`(`int`) ėœ„ėš˜ė˜ ë°”ė´íŠ¸ëĄœ ė´ë™í•Šë‹ˆë‹¤.
        * 똈) `await myfile.seek(0)` ëĨŧ ė‚ŦėšŠí•˜ëŠ´ 파ėŧė˜ ė‹œėž‘ëļ€ëļ„ėœŧ로 ė´ë™í•Šë‹ˆë‹¤.
        * `await myfile.read()` ëĨŧ ė‚ŦėšŠí•œ 후 ë‚´ėšŠė„ ë‹¤ė‹œ ėŊė„ 때 ėœ ėšŠí•Šë‹ˆë‹¤.
    * `close()`: 파ėŧė„ ë‹ĢėŠĩ니다.
    
    냁揰 ëĒ¨ë“  ëŠ”ė†Œë“œë“¤ė´ `async` ëŠ”ė†Œë“œė´ę¸° 때ëŦ¸ė— “awaitâ€ė„ ė‚ŦėšŠí•˜ė—Ŧė•ŧ 합니다.
    
    똈ëĨŧë“¤ė–´, `async` *ę˛Ŋ로 ėž‘ë™ í•¨ėˆ˜*ė˜ 내ëļ€ė—ė„œ ë‹¤ėŒęŗŧ ę°™ė€ ë°Šė‹ėœŧ로 ë‚´ėšŠė„ 氀렏ė˜Ŧ 눘 ėžˆėŠĩ니다:
    
    ```Python
    contents = await myfile.read()
    ```
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Nov 18 02:25:44 UTC 2024
    - 8K bytes
    - Viewed (0)
  5. ci/devinfra/docker/windows/Dockerfile

             'msys2.tar.xz'); \
        Start-Process -FilePath \"C:\Program Files\7-Zip\7z.exe\" -ArgumentList 'x msys2.tar.xz -oC:\TEMP\msys2.tar' -Wait; \
        Start-Process -FilePath \"C:\Program Files\7-Zip\7z.exe\" -ArgumentList 'x C:\TEMP\msys2.tar -oC:\tools' -Wait; \
        $env:PATH = [Environment]::GetEnvironmentVariable('PATH', 'Machine') + ';C:\tools\msys64;C:\tools\msys64\usr\bin\'; \
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Fri Jan 17 16:35:57 UTC 2025
    - 8.4K bytes
    - Viewed (0)
  6. tests/compose.yml

          # timeout handling
          if [ $$counter -gt 20 ]; then
            echo "Error: Database failed to start within timeout";
            exit 1;
          fi;
          # keep the container running: wait for the database process in the foreground
          wait
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Mon Aug 04 04:07:30 UTC 2025
    - 1.9K bytes
    - Viewed (0)
  7. src/main/java/jcifs/internal/smb1/trans/TransWaitNamedPipe.java

    import jcifs.Configuration;
    
    /**
     * SMB1 Transaction Wait Named Pipe request implementation.
     * Implements the TRANS_WAIT_NAMED_PIPE transaction to wait for a named pipe
     * to become available when the pipe server is busy or temporarily unavailable.
     *
     * @author mbechler
     */
    public class TransWaitNamedPipe extends SmbComTransaction {
    
        /**
         * Constructs a wait request for a named pipe.
         *
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  8. src/test/java/jcifs/smb/SmbCopyUtilTest.java

            byte[] payload = new byte[] { 1, 2, 3, 4 };
    
            w.start();
    
            // Wait until writer thread signals readiness
            synchronized (w) {
                long deadline = System.currentTimeMillis() + 2000;
                while (!w.isReady() && System.currentTimeMillis() < deadline) {
                    w.wait(10);
                }
                assertTrue(w.isReady(), "WriterThread should be ready to accept work");
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 12.1K bytes
    - Viewed (0)
  9. src/test/java/jcifs/util/SimpleCircuitBreakerTest.java

        void testTransitionToHalfOpen() throws Exception {
            // Open the circuit
            circuitBreaker.tripBreaker();
            assertEquals(SimpleCircuitBreaker.State.OPEN, circuitBreaker.getState());
    
            // Wait for timeout
            Thread.sleep(150);
    
            // Next call should transition to HALF_OPEN
            String result = circuitBreaker.call(() -> "success");
            assertEquals("success", result);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 10.6K bytes
    - Viewed (0)
  10. cmd/erasure-sets.go

    	g := errgroup.WithNErrs(len(s.sets))
    	for index := range s.sets {
    		g.Go(func() error {
    			storageInfos[index] = s.sets[index].StorageInfo(ctx)
    			return nil
    		}, index)
    	}
    
    	// Wait for the go routines.
    	g.Wait()
    
    	for _, lstorageInfo := range storageInfos {
    		storageInfo.Disks = append(storageInfo.Disks, lstorageInfo.Disks...)
    	}
    
    	return storageInfo
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
Back to top