- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 697 for chan (0.02 sec)
-
internal/lru/lru.go
// // Important: done channel is never closed, so deleteExpired() goroutine will never exit, // it's decided to add functionality to close it in the version later than v2. if res.ttl != noEvictionTTL { go func(done <-chan struct{}) { ticker := time.NewTicker(res.ttl / numBuckets) defer ticker.Stop() for { select { case <-done: return case <-ticker.C: res.deleteExpired()
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Fri Apr 25 08:22:26 UTC 2025 - 12.5K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/google/BiMapGenerators.java
import java.util.Map.Entry; import org.jspecify.annotations.NullMarked; /** * Generators of various {@link com.google.common.collect.BiMap}s and derived collections. * * @author Jared Levy * @author Hayward Chan */ @GwtCompatible @NullMarked public class BiMapGenerators { public static class ImmutableBiMapGenerator extends TestStringBiMapGenerator { @Override
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Aug 10 19:54:19 UTC 2025 - 2.5K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ForwardingImmutableList.java
import java.util.Collection; import java.util.List; import org.jspecify.annotations.Nullable; /** * GWT emulated version of {@link ImmutableList}. TODO(cpovirk): more doc * * @author Hayward Chan */ abstract class ForwardingImmutableList<E> extends ImmutableList<E> { ForwardingImmutableList() {} abstract List<E> delegateList(); @Override public int indexOf(@Nullable Object object) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Aug 06 18:32:41 UTC 2025 - 2.5K bytes - Viewed (0) -
guava-gwt/test-super/com/google/common/collect/testing/super/com/google/common/collect/testing/testers/Platform.java
* limitations under the License. */ package com.google.common.collect.testing.testers; import com.google.common.annotations.GwtCompatible; /** * The emulation source used in GWT. * * @author Hayward Chan */ @GwtCompatible final class Platform { // Use fewer steps in the ListIteratorTester in ListListIteratorTester because it's slow in prod // mode. static int listListIteratorTesterNumIterations() {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 2.3K bytes - Viewed (0) -
src/cmd/api/main_test.go
buf.WriteString("map[") w.writeType(buf, typ.Key()) buf.WriteByte(']') w.writeType(buf, typ.Elem()) case *types.Chan: var s string switch typ.Dir() { case types.SendOnly: s = "chan<- " case types.RecvOnly: s = "<-chan " case types.SendRecv: s = "chan " default: panic("unreachable") } buf.WriteString(s) w.writeType(buf, typ.Elem()) case *types.Alias:
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Thu Feb 20 03:25:33 UTC 2025 - 31.4K bytes - Viewed (0) -
cmd/globals.go
globalIsTLS bool globalTLSCerts *certs.Manager globalHTTPServer *xhttp.Server globalTCPOptions xhttp.TCPOptions globalHTTPServerErrorCh = make(chan error) globalOSSignalCh = make(chan os.Signal, 1) // global Trace system to send HTTP request/response // and Storage/OS calls info to registered listeners. globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Sep 03 18:23:41 UTC 2024 - 16.2K bytes - Viewed (1) -
android/guava-testlib/src/com/google/common/collect/testing/google/ListGenerators.java
public List<Character> create(Character[] elements) { char[] chars = Chars.toArray(asList(elements)); return charactersOf(String.copyValueOf(chars)); } } public static class CharactersOfCharSequenceGenerator extends TestCharacterListGenerator { @Override public List<Character> create(Character[] elements) { char[] chars = Chars.toArray(asList(elements));
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 14:50:24 UTC 2024 - 5K bytes - Viewed (0) -
cmd/metrics-resource.go
func (c *minioResourceCollector) Describe(ch chan<- *prometheus.Desc) { ch <- c.desc } // Collect is called by the Prometheus registry when collecting metrics. func (c *minioResourceCollector) Collect(out chan<- prometheus.Metric) { var wg sync.WaitGroup publish := func(in <-chan MetricV2) { defer wg.Done() for metric := range in {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 17.2K bytes - Viewed (0) -
src/cmd/api/testdata/src/pkg/p1/p1.go
return now } var x = &S{ Public: nil, private: nil, PublicTime: Now(), } var parenExpr = (1 + 5) var funcLit = func() {} var m map[string]int var chanVar chan int var ifaceVar any = 5 var assertVar = ifaceVar.(int) var indexVar = m["foo"] var Byte byte var ByteFunc func(byte) rune type ByteStruct struct { B byte R rune
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Fri Dec 02 16:29:41 UTC 2022 - 3.3K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/google/SortedMapGenerators.java
import org.jspecify.annotations.NullMarked; /** * Generators of sorted maps and derived collections. * * @author Kevin Bourrillion * @author Jesse Wilson * @author Jared Levy * @author Hayward Chan * @author Chris Povirk * @author Louis Wasserman */ @GwtCompatible @NullMarked public class SortedMapGenerators { public static class ImmutableSortedMapGenerator extends TestStringSortedMapGenerator {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Aug 10 19:54:19 UTC 2025 - 4.8K bytes - Viewed (0)