Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 281 - 290 of 312 for Sleep (0.02 seconds)

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

  1. internal/lru/lru.go

    	bucketIdx := c.nextCleanupBucket
    	timeToExpire := time.Until(c.buckets[bucketIdx].newestEntry)
    	// wait for newest entry to expire before cleanup without holding lock
    	if timeToExpire > 0 {
    		c.mu.Unlock()
    		time.Sleep(timeToExpire)
    		c.mu.Lock()
    	}
    	for _, ent := range c.buckets[bucketIdx].entries {
    		c.removeElement(ent)
    	}
    	c.nextCleanupBucket = (c.nextCleanupBucket + 1) % numBuckets
    	c.mu.Unlock()
    }
    
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Mar 21 11:35:55 GMT 2026
    - 12.6K bytes
    - Click Count (0)
  2. internal/logger/target/http/http.go

    				return
    			}
    
    			h.config.LogOnceIf(
    				context.Background(),
    				fmt.Errorf("unable to send audit/log entry(s) to '%s' err '%w': %d", name, err, count),
    				name,
    			)
    
    			time.Sleep(retryIntvl)
    			if maxRetries == 0 {
    				goto retry
    			}
    			retries++
    			if retries <= maxRetries {
    				goto retry
    			}
    		}
    
    		entries = make([]any, 0)
    		count = 0
    		if !isDirQueue {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  3. docs/zh-hant/docs/advanced/custom-response.md

    /// note | 技術細節
    
    一個 `async` 任務只能在抵達某個 `await` 時才能被取消。如果沒有 `await`,該產生器(帶有 `yield` 的函式)將無法被正確取消,甚至在請求取消後仍可能持續執行。
    
    因為這個小範例不需要任何 `await` 陳述式,我們加入 `await anyio.sleep(0)`,讓事件迴圈有機會處理取消。
    
    對於大型或無限的串流來說,這點更為重要。
    
    ///
    
    /// tip
    
    與其直接回傳 `StreamingResponse`,你大概會想遵循[資料串流](./stream-data.md)中的作法,這樣更方便,並且會在底層幫你處理取消。
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 17:05:38 GMT 2026
    - 10.3K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/InterceptorOverridesTest.kt

          }
    
          OverrideParam.ReadTimeout -> {
            client =
              client
                .newBuilder()
                .socketFactory(
                  DelayingSocketFactory(onRead = {
                    Thread.sleep(100L)
                  }),
                ).build()
    
            overrideBadImplementation(override = override.override, testItFails = testItFails)
          }
    
          OverrideParam.ConnectTimeout -> {
            client =
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 11 02:37:00 GMT 2026
    - 28.8K bytes
    - Click Count (0)
  5. tests/upsert_test.go

    	user.Age = 20
    	if err := DB.Create(&user).Error; err != nil {
    		t.Errorf("failed to create user, got error %v", err)
    	}
    
    	var user2 User
    	DB.First(&user2, user.ID)
    	user2.Age = 30
    	time.Sleep(time.Second)
    	if err := DB.Clauses(clause.OnConflict{UpdateAll: true}).Create(&user2).Error; err != nil {
    		t.Fatalf("failed to onconflict create user, got error %v", err)
    	} else {
    		var user3 User
    		DB.First(&user3, user.ID)
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Tue Jul 29 11:06:13 GMT 2025
    - 13.1K bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

        assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
    
        // Give the server time to enact the socket policy if it's one that could happen after the
        // client has received the response.
        Thread.sleep(500)
        val response2 = getResponse(newRequest("/b"))
        response1.body
          .source()
          .timeout()
          .timeout(100, TimeUnit.MILLISECONDS)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 133.3K bytes
    - Click Count (0)
  7. cmd/erasure-server-pool-decom.go

    						}
    						return
    					}
    					if configRetriableErrors(err) {
    						decomLogIf(ctx, fmt.Errorf("Unable to resume decommission of pools %v: %w: retrying..", pools, err))
    						time.Sleep(time.Second + time.Duration(r.Float64()*float64(5*time.Second)))
    						continue
    					}
    					decomLogIf(ctx, fmt.Errorf("Unable to resume decommission of pool %v: %w", pools, err))
    					return
    				}
    			}
    		}()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
  8. cmd/admin-heal-ops.go

    		}
    
    		hsp = madmin.HealStopSuccess{
    			ClientToken:   clientToken,
    			ClientAddress: he.clientAddress,
    			StartTime:     he.startTime,
    		}
    
    		he.stop()
    		for !he.hasEnded() {
    			time.Sleep(1 * time.Second)
    		}
    		ahs.Lock()
    		defer ahs.Unlock()
    		// Heal sequence explicitly stopped, remove it.
    		delete(ahs.healSeqMap, path)
    	}
    
    	b, err := json.Marshal(&hsp)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/thumbnail/ThumbnailManager.java

                        } else {
                            final long interval = fessConfig.getThumbnailGeneratorIntervalAsInteger().longValue();
                            if (interval > 0) {
                                ThreadUtil.sleep(interval);
                            }
                        }
                    } else {
                        logger.warn("Thumbnail generator is not available: name={}", generatorName);
                    }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jan 01 12:47:47 GMT 2026
    - 27.2K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java

                } else if (behavior == 1) { // return null
                  computeNullCount.incrementAndGet();
                  return null;
                } else if (behavior == 2) { // slight delay before returning
                  Thread.sleep(5);
                  computeCount.incrementAndGet();
                  return key;
                } else {
                  computeCount.incrementAndGet();
                  return key;
                }
              }
            };
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 25.7K bytes
    - Click Count (0)
Back to Top