- Sort Score
- Num 10 results
- Language All
Results 121 - 130 of 200 for collocated (0.07 seconds)
-
guava-tests/test/com/google/common/cache/CacheLoadingTest.java
int iterations = 10; WeakReference<Object> ref = new WeakReference<>(null); int expectedComputations = 0; for (int i = 0; i < iterations; i++) { // The entry should get garbage collected and recomputed. Object oldValue = ref.get(); if (oldValue == null) { expectedComputations++; } ref = new WeakReference<>(cache.getUnchecked(1)); oldValue = null;Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 18 18:06:14 GMT 2026 - 91K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/cache/LocalCacheTest.java
// remove absent assertThat(segment.removeEntry(entry, hash, RemovalCause.COLLECTED)).isFalse(); // remove live segment.recordWrite(entry, 1, map.ticker.read()); table.set(0, entry); segment.count = 1; assertThat(segment.removeEntry(entry, hash, RemovalCause.COLLECTED)).isTrue(); assertNotificationEnqueued(map, key, value);Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 18 18:06:14 GMT 2026 - 114.9K bytes - Click Count (0) -
guava-tests/test/com/google/common/cache/LocalCacheTest.java
// remove absent assertThat(segment.removeEntry(entry, hash, RemovalCause.COLLECTED)).isFalse(); // remove live segment.recordWrite(entry, 1, map.ticker.read()); table.set(0, entry); segment.count = 1; assertThat(segment.removeEntry(entry, hash, RemovalCause.COLLECTED)).isTrue(); assertNotificationEnqueued(map, key, value);Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 18 18:06:14 GMT 2026 - 116.4K bytes - Click Count (0) -
cmd/erasure-decode.go
readTriggerCh <- true return } bufIdx := p.readerToBuf[i] if p.buf[bufIdx] == nil { // Reading first time on this disk, hence the buffer needs to be allocated. // Subsequent reads will reuse this buffer. p.buf[bufIdx] = make([]byte, p.shardSize) } // For the last shard, the shardsize might be less than previous shard sizes.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Aug 29 01:40:52 GMT 2024 - 9.5K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java
new ArrayBlockingQueue<Runnable>(1000)); executorService.prestartAllCoreThreads(); AtomicInteger integer = new AtomicInteger(); // Execute a bunch of tasks to ensure that our threads are allocated and hot for (int i = 0; i < NUM_THREADS * 10; i++) { @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored Future<?> possiblyIgnoredError =
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jul 16 17:42:14 GMT 2025 - 15.8K bytes - Click Count (0) -
misc/cgo/gmp/gmp.go
holding the C pointers and use runtime.SetFinalizer on those Go objects. It is much more difficult for the C world to have pointers into the Go world, because the Go garbage collector is unaware of the memory allocated by C. The most important consideration is not to constrain future implementations, so the rule is that Go code can hand a Go pointer to C code but must separately arrange for
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Mon Apr 11 16:34:30 GMT 2022 - 9.5K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/execution/MavenSession.java
public Properties getUserProperties() { return request.getUserProperties(); } /** * Gets the system properties to use for interpolation and profile activation. The system properties are collected * from the runtime environment like {@link System#getProperties()} and environment variables. * * @return The system properties, never {@code null}. */ public Properties getSystemProperties() {
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Jan 24 17:29:44 GMT 2025 - 16.7K bytes - Click Count (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/DependencyResolverRequest.java
* Creates a request with the specified properties. * * @param session {@link Session} * @param rootArtifact The root dependency whose transitive dependencies should be collected, may be {@code * null}. */ @SuppressWarnings("checkstyle:ParameterNumber") DefaultDependencyResolverRequest(Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Oct 10 07:30:49 GMT 2025 - 23K bytes - Click Count (0) -
internal/s3select/message.go
// // 3. If caller is done, it waits for this go-routine to exit // in Finish() quitFlag := false for !quitFlag { select { case data := <-writer.errCh: quitFlag = true // Flush collected records before sending error message if !writer.flushRecords() { break } writer.write(data) case payload, ok := <-writer.payloadCh: if !ok { // payloadCh is closed by caller to
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 15.3K bytes - Click Count (0) -
android/guava/src/com/google/common/io/ByteStreams.java
// streams. Buffers are retained in a deque so that there's no copying between buffers while // reading and so all of the bytes in each new allocated buffer are available for reading from // the stream. for (int bufSize = initialBufferSize; totalLen < MAX_ARRAY_LEN; bufSize = IntMath.saturatedMultiply(bufSize, bufSize < 4096 ? 4 : 2)) {
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)