Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 319 for goroutines (0.17 sec)

  1. security/pkg/nodeagent/caclient/providers/citadel/leak_test.go

    // limitations under the License.
    
    package citadel
    
    import (
    	"testing"
    
    	"istio.io/istio/tests/util/leak"
    )
    
    func TestMain(m *testing.M) {
    	// CheckMain asserts that no goroutines are leaked after a test package exits.
    	leak.CheckMain(m)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 24 21:03:23 UTC 2024
    - 792 bytes
    - Viewed (0)
  2. src/cmd/vendor/golang.org/x/tools/go/analysis/passes/loopclosure/doc.go

    // In addition, it has a data race because the loop updates v
    // concurrent with the goroutines accessing it.
    //
    //	for _, v := range elem {
    //	    go func() {
    //	        use(v)  // incorrect, and a data race
    //	    }()
    //	}
    //
    // A fix is the same as before. The checker also reports problems
    // in goroutines started by golang.org/x/sync/errgroup.Group.
    // A hard-to-spot variant of this form is common in parallel tests:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Nov 20 21:52:54 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  3. src/internal/trace/testdata/testprog/iter-pull.go

    	// Try simple pull iteration.
    	i := pullRange(100)
    	for {
    		_, ok := i.next()
    		if !ok {
    			break
    		}
    	}
    
    	// Try bouncing the pull iterator between two goroutines.
    	var wg sync.WaitGroup
    	var iterChans [2]chan intIter
    	wg.Add(2)
    	iterChans[0] = make(chan intIter)
    	iterChans[1] = make(chan intIter)
    	go func() {
    		defer wg.Done()
    
    		iter := pullRange(100)
    		iterChans[1] <- iter
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  4. src/sync/atomic/value.go

    	}
    	vp := (*efaceWords)(unsafe.Pointer(v))
    	vlp := (*efaceWords)(unsafe.Pointer(&val))
    	for {
    		typ := LoadPointer(&vp.typ)
    		if typ == nil {
    			// Attempt to start first store.
    			// Disable preemption so that other goroutines can use
    			// active spin wait to wait for completion.
    			runtime_procPin()
    			if !CompareAndSwapPointer(&vp.typ, nil, unsafe.Pointer(&firstStoreInProgress)) {
    				runtime_procUnpin()
    				continue
    			}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 26 20:48:55 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  5. pkg/kube/inject/leak_test.go

    // limitations under the License.
    
    package inject
    
    import (
    	"testing"
    
    	"istio.io/istio/tests/util/leak"
    )
    
    func TestMain(m *testing.M) {
    	// CheckMain asserts that no goroutines are leaked after a test package exits.
    	leak.CheckMain(m)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 28 04:22:19 UTC 2024
    - 791 bytes
    - Viewed (0)
  6. pilot/pkg/networking/core/leak_test.go

    // limitations under the License.
    
    package core
    
    import (
    	"testing"
    
    	"istio.io/istio/tests/util/leak"
    )
    
    func TestMain(m *testing.M) {
    	// CheckMain asserts that no goroutines are leaked after a test package exits.
    	leak.CheckMain(m)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 789 bytes
    - Viewed (0)
  7. src/os/tempfile.go

    // The file is created with mode 0o600 (before umask).
    // If dir is the empty string, CreateTemp uses the default directory for temporary files, as returned by [TempDir].
    // Multiple programs or goroutines calling CreateTemp simultaneously will not choose the same file.
    // The caller can use the file's Name method to find the pathname of the file.
    // It is the caller's responsibility to remove the file when it is no longer needed.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 12 18:04:39 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  8. src/cmd/cgo/internal/testcshared/testdata/libgo4/libgo4.go

    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    package main
    
    import "C"
    
    import (
    	"fmt"
    	"os"
    	"runtime"
    )
    
    // RunGoroutines starts some goroutines that don't do anything.
    // The idea is to get some threads going, so that a signal will be delivered
    // to a thread started by Go.
    //
    //export RunGoroutines
    func RunGoroutines() {
    	for i := 0; i < 4; i++ {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 12 11:59:56 UTC 2023
    - 864 bytes
    - Viewed (0)
  9. src/internal/singleflight/singleflight.go

    }
    
    // ForgetUnshared tells the singleflight to forget about a key if it is not
    // shared with any other goroutines. Future calls to Do for a forgotten key
    // will call the function rather than waiting for an earlier call to complete.
    // Returns whether the key was forgotten or unknown--that is, whether no
    // other goroutines are waiting for the result.
    func (g *Group) ForgetUnshared(key string) bool {
    	g.mu.Lock()
    	defer g.mu.Unlock()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Sep 30 20:49:56 UTC 2022
    - 3.1K bytes
    - Viewed (0)
  10. src/cmd/cgo/internal/testnocgo/nocgo.go

    // when -static is expected to work.
    
    package nocgo
    
    func NoCgo() int {
    	c := make(chan int)
    
    	// The test is run with external linking, which means that
    	// goroutines will be created via the runtime/cgo package.
    	// Make sure that works.
    	go func() {
    		c <- 42
    	}()
    
    	return <-c
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 12 12:00:02 UTC 2023
    - 574 bytes
    - Viewed (0)
Back to top