- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for GoChan (0.12 sec)
-
src/cmd/cgo/out.go
case *ast.MapType: return &Type{Size: p.PtrSize, Align: p.PtrSize, C: c("GoMap")} case *ast.ChanType: return &Type{Size: p.PtrSize, Align: p.PtrSize, C: c("GoChan")} case *ast.Ident: goTypesFixup := func(r *Type) *Type { if r.Size == 0 { // int or uint rr := new(Type) *rr = *r rr.Size = p.IntSize rr.Align = p.IntSize r = rr
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 29 16:41:10 UTC 2024 - 59.6K bytes - Viewed (0) -
src/internal/singleflight/singleflight.go
} c := new(call) c.wg.Add(1) g.m[key] = c g.mu.Unlock() g.doCall(c, key, fn) return c.val, c.err, c.dups > 0 } // DoChan is like Do but returns a channel that will receive the // results when they are ready. func (g *Group) DoChan(key string, fn func() (any, error)) <-chan Result { ch := make(chan Result, 1) g.mu.Lock() if g.m == nil { g.m = make(map[string]*call) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 30 20:49:56 UTC 2022 - 3.1K bytes - Viewed (0) -
test/stress/runstress.go
"os/exec" "strconv" "time" ) var ( v = flag.Bool("v", false, "verbose") doMaps = flag.Bool("maps", true, "stress maps") doExec = flag.Bool("exec", true, "stress exec") doChan = flag.Bool("chan", true, "stress channels") doNet = flag.Bool("net", true, "stress networking") doParseGo = flag.Bool("parsego", true, "stress parsing Go (generates garbage)") ) func Println(a ...interface{}) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:21:35 UTC 2024 - 3.6K bytes - Viewed (0) -
src/internal/singleflight/singleflight_test.go
go func() { g.Do(key, func() (i interface{}, e error) { // Notify that we started secondCh <- struct{}{} <-secondCh return 2, nil }) }() <-secondCh resultCh := g.DoChan(key, func() (i interface{}, e error) { panic("third must not be started") }) if g.ForgetUnshared(key) { t.Errorf("Before first goroutine finished, key %q is shared, should return false", key) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 29 22:21:50 UTC 2023 - 3.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/token/cache/cached_token_authenticator.go
doneAuthenticating(true) return record } // Record cache miss doneBlocking := stats.blocking(ctx) defer doneBlocking() defer doneAuthenticating(false) c := a.group.DoChan(key, func() (val interface{}, _ error) { // always use one place to read and write the output of AuthenticateToken record := &cacheRecord{} doneFetching := stats.fetching(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 16:16:51 UTC 2023 - 9.8K bytes - Viewed (0) -
go.work.sum
github.com/mitchellh/go-testing-interface v1.0.0 h1:fzU/JVNcaqHQEcVFAKeR41fkiLdIPrefOvVG1VZ96U0= github.com/mitchellh/gox v0.4.0 h1:lfGJxY7ToLJQjHHwi0EX6uYBdK78egf954SQl13PQJc= github.com/mitchellh/iochan v1.0.0 h1:C+X3KsSTLFVBr/tK1eYN/vs4rJcvsiLU338UhYPJWeY= github.com/mitchellh/mapstructure v1.1.2 h1:fmNYVwqnSfB9mZU6OS2O6GsXM+wcskZDuKQzvN1EDeE= github.com/morikuni/aec v1.0.0 h1:nP9CBfwrvYnBRgY6qfDQkygYDmYwOilePFkwzv4dU8A=
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:12 UTC 2024 - 30.9K bytes - Viewed (0) -
src/net/lookup.go
lookupGroupCtx, lookupGroupCancel := context.WithCancel(withUnexpiredValuesPreserved(ctx)) lookupKey := network + "\000" + host dnsWaitGroup.Add(1) ch := r.getLookupGroup().DoChan(lookupKey, func() (any, error) { return testHookLookupIP(lookupGroupCtx, resolverFunc, network, host) }) dnsWaitGroupDone := func(ch <-chan singleflight.Result, cancelFn context.CancelFunc) { <-ch
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:23:45 UTC 2024 - 28.6K bytes - Viewed (0) -
internal/s3select/select_test.go
withJSON: `{ "person": [ { "Id": 1, "Name": "Anshu", "Address": "Templestowe", "Car": "Jeep" }, { "Id": 2, "Name": "Ben Mostafa", "Address": "Las Vegas", "Car": "Mustang" }, { "Id": 3, "Name": "Rohan Wood", "Address": "Wooddon", "Car": "VW" } ] }`, }, { name: "lower-case-is", query: `select * from s3object[*] as s where s.request.header['User-Agent'] is not null`,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Dec 23 07:19:11 UTC 2023 - 76.2K bytes - Viewed (0) -
go.sum
github.com/mitchellh/go-wordwrap v1.0.1/go.mod h1:R62XHJLzvMFRBbcrT7m7WgmE1eOyTSsCt+hzestvNj0= github.com/mitchellh/gox v0.4.0/go.mod h1:Sd9lOJ0+aimLBi73mGofS1ycjY8lL3uZM3JPS42BGNg= github.com/mitchellh/iochan v1.0.0/go.mod h1:JwYml1nuB7xOzsp52dPpHFffvOCDupsG0QubkSMEySY= github.com/mitchellh/mapstructure v0.0.0-20160808181253-ca63d7c062ee/go.mod h1:FVVH3fgwuzCH5S8UJGiWEs2h04kUh9fWfEaFds41c1Y=
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 21:47:11 UTC 2024 - 93.1K bytes - Viewed (0) -
RELEASE.md
Frederic Bastien, gadagashwini, Gauri1 Deshpande, Georgiy Manuilov, Guilherme De Lázari, Guozhong Zhuang, H1Gdev, homuler, Hongxu Jia, Jacky_Yin, jayfurmanek, jgehw, Jhalak Patel, Jinzhe Zeng, Johan Gunnarsson, Jonathan Dekhtiar, Kaixi Hou, Kanvi Khanna, Kevin Cheng, Koan-Sin Tan, Kruglov-Dmitry, Kun Lu, Lemo, Lequn Chen, long.chen, Louis Sugy, Mahmoud Abuzaina, Mao, Marius Brehler, Mark
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Jun 11 23:24:08 UTC 2024 - 730.3K bytes - Viewed (0)