- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 121 for lock4 (0.05 sec)
-
kotlin-js-store/yarn.lock
Yuri Schimke <******@****.***> 1690028931 +0100
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jul 22 12:28:51 UTC 2023 - 87.4K bytes - Viewed (0) -
src/runtime/mgc.go
mheap_.reclaimIndex.Store(0) mheap_.reclaimCredit.Store(0) unlock(&mheap_.lock) sweep.centralIndex.clear() if !concurrentSweep || mode == gcForceBlockMode { // Special case synchronous sweep. // Record that no proportional sweeping has to happen. lock(&mheap_.lock) mheap_.sweepPagesPerByte = 0 unlock(&mheap_.lock) // Flush all mcaches. for _, pp := range allp {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 62K bytes - Viewed (0) -
src/runtime/mheap.go
// allocate a new arena. lock(&gcBitsArenas.lock) // Try the head arena again, since it may have changed. Now // that we hold the lock, the list head can't change, but its // free position still can. if p := gcBitsArenas.next.tryAlloc(bytesNeeded); p != nil { unlock(&gcBitsArenas.lock) return p } // Allocate a new arena. This may temporarily drop the lock. fresh := newArenaMayUnlock()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:31:00 UTC 2024 - 78K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
Delay time.Duration } type fakeQueue struct { lock sync.Mutex queue []FakeQueueItem currentStart int } func (q *fakeQueue) Empty() bool { q.lock.Lock() defer q.lock.Unlock() return (len(q.queue) - q.currentStart) == 0 } func (q *fakeQueue) Items() []FakeQueueItem { q.lock.Lock() defer q.lock.Unlock() return append(make([]FakeQueueItem, 0, len(q.queue)), q.queue...)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
func (p *PriorityQueue) Close() { p.lock.Lock() defer p.lock.Unlock() close(p.stop) p.closed = true p.cond.Broadcast() } // DeleteNominatedPodIfExists deletes <pod> from nominatedPods. func (npm *nominator) DeleteNominatedPodIfExists(pod *v1.Pod) { npm.lock.Lock() npm.deleteNominatedPodIfExistsUnlocked(pod) npm.lock.Unlock() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
src/runtime/mgcmark.go
func gcParkAssist() bool { lock(&work.assistQueue.lock) // If the GC cycle finished while we were getting the lock, // exit the assist. The cycle can't finish while we hold the // lock. if atomic.Load(&gcBlackenEnabled) == 0 { unlock(&work.assistQueue.lock) return true } gp := getg() oldList := work.assistQueue.q work.assistQueue.q.pushBack(gp)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 18 21:25:11 UTC 2024 - 52.5K bytes - Viewed (0) -
src/runtime/mprof.go
// // There are several steps between the time that an M experiences contention and // when that contention may be added to the profile. This comes from our // constraints: We need to keep the critical section of each lock small, // especially when those locks are contended. The reporting code cannot acquire // new locks until the M has released all other locks, which means no memory
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 53.3K bytes - Viewed (0) -
pkg/volume/testing/testing.go
func (plugin *FakeVolumePlugin) NewMounter(spec *volume.Spec, pod *v1.Pod, opts volume.VolumeOptions) (volume.Mounter, error) { plugin.Lock() defer plugin.Unlock() if spec.Name() == FailNewMounter { return nil, fmt.Errorf("AlwaysFailNewMounter") } fakeVolume := plugin.getFakeVolume(&plugin.Mounters) fakeVolume.Lock() defer fakeVolume.Unlock() fakeVolume.PodUID = pod.UID fakeVolume.VolName = spec.Name() fakeVolume.Plugin = plugin
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 53.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
* cancelled without a call to {@code cancel}, such as by calling {@code * setFuture(cancelledFuture)}. * * <p>Beware of completing a future while holding a lock. Its listeners may do slow work or * acquire other locks, risking deadlocks. */ @CanIgnoreReturnValue @Override public boolean cancel(boolean mayInterruptIfRunning) { Object localValue = value; boolean rValue = false;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 63.1K bytes - Viewed (1) -
guava/src/com/google/common/util/concurrent/AbstractFuture.java
* cancelled without a call to {@code cancel}, such as by calling {@code * setFuture(cancelledFuture)}. * * <p>Beware of completing a future while holding a lock. Its listeners may do slow work or * acquire other locks, risking deadlocks. */ @CanIgnoreReturnValue @Override public boolean cancel(boolean mayInterruptIfRunning) { Object localValue = value; boolean rValue = false;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 62.8K bytes - Viewed (1)