Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 221 - 230 of 612 for kuwait (0.04 seconds)

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

  1. android/guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java

       * Last, but not least: consider a RateLimiter with rate of 1 permit per second, currently
       * completely unused, and an expensive acquire(100) request comes. It would be nonsensical to just
       * wait for 100 seconds, and /then/ start the actual task. Why wait without doing anything? A much
       * better approach is to /allow/ the request right away (as if it was an acquire(1) request
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed May 14 19:40:47 GMT 2025
    - 19.3K bytes
    - Click Count (0)
  2. internal/grid/grid_test.go

    				close(reqStarted)
    				// Just wait for it to cancel.
    				for blockResp {
    					select {
    					case <-ctx.Done():
    						close(serverCanceled)
    						return NewRemoteErr(ctx.Err())
    					case resp <- []byte{1}:
    						time.Sleep(10 * time.Millisecond)
    					}
    				}
    				// Just wait for it to cancel.
    				<-ctx.Done()
    				close(serverCanceled)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.1K bytes
    - Click Count (0)
  3. .github/dependabot.yml

    version: 2
    updates:
    # TODO(b/170636568): Enable Maven updates? Perhaps wait until we can more
    # easily import the generated PRs into our internal repo.
    #  - package-ecosystem: "maven"
    #    directory: "/"
    #    schedule:
    #      interval: "weekly"
    #    groups:
    #      dependencies:
    #        applies-to: version-updates
    #        patterns:
    #          - "*"
    #  - package-ecosystem: "maven"
    #    directory: "/android"
    #    schedule:
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Jan 06 17:34:37 GMT 2026
    - 995 bytes
    - Click Count (0)
  4. schema/schema.go

    		schemaCacheKey = fmt.Sprintf("%p-%s", modelType, specialTableName)
    	}
    
    	// Load exist schema cache, return if exists
    	if v, ok := cacheStore.Load(schemaCacheKey); ok {
    		s := v.(*Schema)
    		// Wait for the initialization of other goroutines to complete
    		<-s.initialized
    		return s, s.err
    	}
    
    	var tableName string
    	modelValue := reflect.New(modelType)
    	if specialTableName != "" {
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Mar 21 11:35:55 GMT 2026
    - 13.3K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

        // (which will block) in the same thread.
        new Thread() {
          @Override
          public void run() {
            inputFuture.set(SLOW_FUNC_VALID_INPUT_DATA);
          }
        }.start();
        funcIsWaitingLatch.await();
    
        assertTrue(resultFuture.cancel(true));
        assertTrue(resultFuture.isCancelled());
        assertFalse(inputFuture.isCancelled());
        assertFalse(outputFuture.isCancelled());
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 6.5K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

        // (which will block) in the same thread.
        new Thread() {
          @Override
          public void run() {
            inputFuture.set(SLOW_FUNC_VALID_INPUT_DATA);
          }
        }.start();
        funcIsWaitingLatch.await();
    
        assertTrue(resultFuture.cancel(true));
        assertTrue(resultFuture.isCancelled());
        assertFalse(inputFuture.isCancelled());
        assertFalse(outputFuture.isCancelled());
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 6.5K bytes
    - Click Count (0)
  7. docs/ru/docs/advanced/dataclasses.md

        Как и всегда в FastAPI, вы можете сочетать `def` и `async def` по необходимости.
    
        Если хотите освежить в памяти, когда что использовать, посмотрите раздел _"Нет времени?"_ в документации про [`async` и `await`](../async.md#in-a-hurry).
    
    9. Эта *функция-обработчик пути* возвращает не dataclasses (хотя могла бы), а список словарей с внутренними данными.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 17:56:20 GMT 2026
    - 6.4K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/collect/Queues.java

       * numElements} elements are not available, it will wait for them up to the specified timeout.
       *
       * @param q the blocking queue to be drained
       * @param buffer where to add the transferred elements
       * @param numElements the number of elements to be waited for
       * @param timeout how long to wait before giving up
       * @return the number of elements transferred
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 18.2K bytes
    - Click Count (0)
  9. docs/ja/docs/advanced/stream-data.md

    この例では `io.BytesIO` によるメモリ内の疑似ファイルなので重要度は高くありませんが、実ファイルの場合は処理後に確実にクローズすることが重要です。
    
    ### ファイルと非同期 { #files-and-async }
    
    多くの場合、ファイルライクオブジェクトはデフォルトでは async/await と互換性がありません。
    
    例えば、`await file.read()` や `async for chunk in file` のような操作は提供されていません。
    
    また、多くの場合、ディスクやネットワークから読み出すため、読み取りはブロッキング(イベントループをブロックし得る)処理になります。
    
    /// info | 情報
    
    上記の例は例外で、`io.BytesIO` は既にメモリ上にあるため、読み取りが何かをブロックすることはありません。
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:55:22 GMT 2026
    - 6.7K bytes
    - Click Count (0)
  10. cmd/perf-tests.go

    				atomic.AddUint64(&totalBytesWritten, uint64(info.Size))
    				objCountPerThread[i]++
    				mu.Lock()
    				uploadTimes = append(uploadTimes, response)
    				mu.Unlock()
    			}
    		}(i)
    	}
    	wg.Wait()
    
    	// We already saw write failures, no need to proceed into read's
    	if retError != "" {
    		return SpeedTestResult{
    			Uploads:     totalBytesWritten,
    			Downloads:   totalBytesRead,
    			UploadTimes: uploadTimes,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.8K bytes
    - Click Count (0)
Back to Top