Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for GoChan (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top