- Sort Score
- Num 10 results
- Language All
Results 1 - 8 of 8 for unbuffered (0.1 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
doc/godebug.md
can be controlled with the `x509rsacrt` setting. Using `x509rsacrt=0` restores the Go 1.23 behavior. ### Go 1.23 Go 1.23 changed the channels created by package time to be unbuffered (synchronous), which makes correct use of the [`Timer.Stop`](/pkg/time/#Timer.Stop) and [`Timer.Reset`](/pkg/time/#Timer.Reset) method results much easier.
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Fri Mar 20 15:49:10 GMT 2026 - 26K bytes - Click Count (0) -
doc/go_spec.html
make(chan int, 100) </pre> <p> The capacity, in number of elements, sets the size of the buffer in the channel. If the capacity is zero or absent, the channel is unbuffered and communication succeeds only when both a sender and receiver are ready. Otherwise, the channel is buffered and communication succeeds without blocking if the buffer is not full (sends) or not empty (receives). A <code>nil</code> channel is never ready for communication.
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Wed Apr 01 23:39:18 GMT 2026 - 287.8K bytes - Click Count (1) -
src/main/java/org/codelibs/fess/timer/LogNotificationTarget.java
import org.codelibs.fess.util.ComponentUtil; import org.opensearch.action.bulk.BulkRequestBuilder; import org.opensearch.action.bulk.BulkResponse; /** * A timer target that periodically flushes buffered log notification events * to an OpenSearch index for downstream processing. */ public class LogNotificationTarget implements TimeoutTarget { /** * Default constructor. */Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 02:24:08 GMT 2026 - 4.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/LogNotificationHelper.java
size.decrementAndGet(); } } } /** * Drains all events from the buffer and returns them as a list. * * @return a list of all buffered events */ public List<LogNotificationEvent> drainAll() { final List<LogNotificationEvent> events = new ArrayList<>(); LogNotificationEvent event; while ((event = queue.poll()) != null) {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 02:24:08 GMT 2026 - 5.3K bytes - Click Count (0) -
android/guava/src/com/google/common/io/ByteStreams.java
byte[] buf = null; while (totalSkipped < n) { long remaining = n - totalSkipped; long skipped = skipSafely(in, remaining); if (skipped == 0) { // Do a buffered read since skipSafely could return 0 repeatedly, for example if // in.available() always returns 0 (the default). int skip = (int) min(remaining, BUFFER_SIZE); if (buf == null) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 31.1K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/MapMakerInternalMap.java
/** Number of (unsynchronized) retries in the containsValue method. */ static final int CONTAINS_VALUE_RETRIES = 3; /** * Number of cache access operations that can be buffered per segment before the cache's recency * ordering information is updated. This is used to avoid lock contention by recording a memento
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 89.9K bytes - Click Count (0) -
android/guava/src/com/google/common/cache/LocalCache.java
/** Number of (unsynchronized) retries in the containsValue method. */ static final int CONTAINS_VALUE_RETRIES = 3; /** * Number of cache access operations that can be buffered per segment before the cache's recency * ordering information is updated. This is used to avoid lock contention by recording a memento
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 143.5K bytes - Click Count (0) -
guava/src/com/google/common/cache/LocalCache.java
/** Number of (unsynchronized) retries in the containsValue method. */ static final int CONTAINS_VALUE_RETRIES = 3; /** * Number of cache access operations that can be buffered per segment before the cache's recency * ordering information is updated. This is used to avoid lock contention by recording a memento
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 148.9K bytes - Click Count (0)