Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for Runtime_procUnpin (1.23 sec)

  1. src/sync/atomic/value.go

    			runtime_procPin()
    			if !CompareAndSwapPointer(&vp.typ, nil, unsafe.Pointer(&firstStoreInProgress)) {
    				runtime_procUnpin()
    				continue
    			}
    			// Complete first store.
    			StorePointer(&vp.data, vlp.data)
    			StorePointer(&vp.typ, vlp.typ)
    			runtime_procUnpin()
    			return
    		}
    		if typ == unsafe.Pointer(&firstStoreInProgress) {
    			// First store in progress. Wait.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 26 20:48:55 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  2. src/sync/export_test.go

    package sync
    
    // Export for testing.
    var Runtime_Semacquire = runtime_Semacquire
    var Runtime_Semrelease = runtime_Semrelease
    var Runtime_procPin = runtime_procPin
    var Runtime_procUnpin = runtime_procUnpin
    
    // poolDequeue testing.
    type PoolDequeue interface {
    	PushHead(val any) bool
    	PopHead() (any, bool)
    	PopTail() (any, bool)
    }
    
    func NewPoolDequeue(n int) PoolDequeue {
    	d := &poolDequeue{
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Nov 17 16:39:52 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  3. src/sync/pool.go

    			return
    		}
    		race.ReleaseMerge(poolRaceAddr(x))
    		race.Disable()
    	}
    	l, _ := p.pin()
    	if l.private == nil {
    		l.private = x
    	} else {
    		l.shared.pushHead(x)
    	}
    	runtime_procUnpin()
    	if race.Enabled {
    		race.Enable()
    	}
    }
    
    // Get selects an arbitrary item from the [Pool], removes it from the
    // Pool, and returns it to the caller.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 9.4K bytes
    - Viewed (1)
  4. src/sync/pool_test.go

    	if g := p.Get(); g != "a" {
    		t.Fatalf("got %#v; want a", g)
    	}
    	if g := p.Get(); g != "b" {
    		t.Fatalf("got %#v; want b", g)
    	}
    	if g := p.Get(); g != nil {
    		t.Fatalf("got %#v; want nil", g)
    	}
    	Runtime_procUnpin()
    
    	// Put in a large number of objects so they spill into
    	// stealable space.
    	for i := 0; i < 100; i++ {
    		p.Put("c")
    	}
    	// After one GC, the victim cache should keep them alive.
    	runtime.GC()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 8K bytes
    - Viewed (0)
  5. src/runtime/proc.go

    }
    
    //go:linkname sync_runtime_procUnpin sync.runtime_procUnpin
    //go:nosplit
    func sync_runtime_procUnpin() {
    	procUnpin()
    }
    
    //go:linkname sync_atomic_runtime_procPin sync/atomic.runtime_procPin
    //go:nosplit
    func sync_atomic_runtime_procPin() int {
    	return procPin()
    }
    
    //go:linkname sync_atomic_runtime_procUnpin sync/atomic.runtime_procUnpin
    //go:nosplit
    func sync_atomic_runtime_procUnpin() {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 207.5K bytes
    - Viewed (0)
Back to top