Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 301 - 310 of 787 for kuwait (0.04 seconds)

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

          lock.lock();
          try {
            locked.countDown();
            finishLatch.await(1, MINUTES);
          } catch (InterruptedException e) {
            fail(e.toString());
          } finally {
            lock.unlock();
          }
        }
    
        void waitUntilHoldingLock() throws InterruptedException {
          locked.await(1, MINUTES);
        }
    
        void releaseLockAndFinish() throws InterruptedException {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 16.3K bytes
    - Click Count (0)
  2. docs/zh-hant/docs/advanced/events.md

    ```Python
    with open("file.txt") as file:
        file.read()
    ```
    
    在較新的 Python 版本中,也有**非同步內容管理器**。你可以用 `async with` 來使用它:
    
    ```Python
    async with lifespan(app):
        await do_stuff()
    ```
    
    當你像上面那樣建立一個內容管理器或非同步內容管理器時,在進入 `with` 區塊之前,會先執行 `yield` 之前的程式碼;離開 `with` 區塊之後,會執行 `yield` 之後的程式碼。
    
    在我們的範例中,並不是直接用它,而是把它傳給 FastAPI 來使用。
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 17:05:38 GMT 2026
    - 7.2K bytes
    - Click Count (0)
  3. internal/dsync/dsync_test.go

    	cancel := func() {
    		cl()
    		wg.Done()
    	}
    
    	if !dm.GetLock(ctx, cancel, id, source, Options{Timeout: 5 * time.Minute}) {
    		t.Fatal("GetLock() should be successful")
    	}
    
    	// Wait until context is canceled
    	wg.Wait()
    	if ctx.Err() == nil {
    		t.Fatal("Unexpected error", ctx.Err())
    	}
    
    	// Should be safe operation in all cases
    	dm.Unlock(t.Context())
    }
    
    // Test Unlock should not timeout
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  4. docs/releasing.md

        git push && git push --tags
    
       sed -i "" \
          "s/version = \".*\"/version = \"$NEXT_VERSION\"/g" \
          build.gradle.kts
        git commit -am "Prepare next development version."
        git push
        ```
    
    4. Wait for [GitHub Actions][github_actions] to build and promote the release.
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Nov 19 15:45:22 GMT 2025
    - 1.1K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

        peer.acceptFrame() // RST_STREAM
        peer.acceptFrame() // DEGRADED PING
        peer.acceptFrame() // AWAIT PING
        peer.sendFrame().ping(true, Http2Connection.DEGRADED_PING, 1) // DEGRADED PONG
        peer.sendFrame().ping(true, Http2Connection.AWAIT_PING, 0) // AWAIT PONG
        peer.play()
    
        // Play it back.
        val connection = connect(peer)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 75.5K bytes
    - Click Count (0)
  6. cmd/untar.go

    				return err
    			}
    		}
    
    		header, err := tarReader.Next()
    		switch {
    		// if no more files are found return
    		case err == io.EOF:
    			wg.Wait()
    			return asyncErr
    
    		// return any other error
    		case err != nil:
    			wg.Wait()
    			extra := ""
    			if n > 0 {
    				extra = fmt.Sprintf(" after %d successful object(s)", n)
    			}
    			return fmt.Errorf("tar file error: %w%s", err, extra)
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 6K bytes
    - Click Count (2)
  7. tests/prepared_stmt_test.go

    	if lens == 0 {
    		// If the number is 0, it means there are no statements stored in the LRU cache.
    		// The test fails and an error message is output.
    		t.Fatalf("lru should not be empty")
    	}
    	// Wait for 40 seconds to give the statements in the cache enough time to expire.
    	time.Sleep(time.Second * 40)
    	// Assert whether the connection pool of tx is successfully converted to the *gorm.PreparedStmtDB type.
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Fri Apr 25 08:22:26 GMT 2025
    - 8K bytes
    - Click Count (0)
  8. cmd/format-erasure.go

    			if formats[index] == nil {
    				return errDiskNotFound
    			}
    			return saveFormatErasure(storageDisks[index], formats[index], "")
    		}, index)
    	}
    
    	// Wait for the routines to finish.
    	return reduceWriteQuorumErrs(ctx, g.Wait(), nil, len(storageDisks))
    }
    
    // relinquishes the underlying connection for all storage disks.
    func closeStorageDisks(storageDisks ...StorageAPI) {
    	var wg sync.WaitGroup
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 23.1K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt

        }
      }
    
      /**
       * Like [Object.wait], but throws an [InterruptedIOException] when interrupted instead of the more
       * awkward [InterruptedException].
       */
      @Throws(InterruptedIOException::class)
      internal fun waitForIo() {
        try {
          wait()
        } catch (_: InterruptedException) {
          Thread.currentThread().interrupt() // Retain interrupted status.
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Jul 07 18:57:05 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

       * than the given time. The manager will become healthy after all the component services have
       * reached the {@linkplain State#RUNNING running} state.
       *
       * @param timeout the maximum time to wait
       * @throws TimeoutException if not all of the services have finished starting within the deadline
       * @throws IllegalStateException if the service manager reaches a state from which it cannot
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 33.2K bytes
    - Click Count (1)
Back to Top