Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for popHead (0.12 sec)

  1. src/sync/poolqueue.go

    	// and acts as a store barrier for writing the slot.
    	d.headTail.Add(1 << dequeueBits)
    	return true
    }
    
    // popHead removes and returns the element at the head of the queue.
    // It returns false if the queue is empty. It must only be called by a
    // single producer.
    func (d *poolDequeue) popHead() (any, bool) {
    	var slot *eface
    	for {
    		ptrs := d.headTail.Load()
    		head, tail := d.unpack(ptrs)
    		if tail == head {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 26 18:12:29 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  2. src/sync/pool_test.go

    		}
    	}
    	// Check that at least some PopHeads succeeded. We skip this
    	// check in short mode because it's common enough that the
    	// queue will stay nearly empty all the time and a PopTail
    	// will happen during the window between every PushHead and
    	// PopHead.
    	if !testing.Short() && nPopHead == 0 {
    		t.Errorf("popHead never succeeded")
    	}
    }
    
    func TestNilPool(t *testing.T) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 8K bytes
    - Viewed (0)
  3. src/sync/pool.go

    	New func() any
    }
    
    // Local per-P Pool appendix.
    type poolLocalInternal struct {
    	private any       // Can be used only by the respective P.
    	shared  poolChain // Local P can pushHead/popHead; any P can popTail.
    }
    
    type poolLocal struct {
    	poolLocalInternal
    
    	// Prevents false sharing on widespread platforms with
    	// 128 mod (cache line size) = 0 .
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  4. src/runtime/mspanset.go

    		if block != nil {
    			// Check the popped value.
    			if block.popped.Load() == 0 {
    				// popped should never be zero because that means we have
    				// pushed at least one value but not yet popped if this
    				// block pointer is not nil.
    				throw("span set block with unpopped elements found in reset")
    			}
    			if block.popped.Load() == spanSetBlockEntries {
    				// popped should also never be equal to spanSetBlockEntries
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  5. platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r70/TestDisplayNameJUnit5CrossVersionSpec.groovy

                                    test("throwsExceptionWhenPopped()") {
                                        operationDisplayName "throws EmptyStackException when popped"
                                        testDisplayName "throws EmptyStackException when popped"
                                    }
                                    testClass("org.example.TestingAStackDemo\$WhenNew\$AfterPushing") {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 16 10:10:39 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  6. platforms/core-execution/execution/src/main/java/org/gradle/internal/execution/history/impl/FileSystemSnapshotSerializer.java

            }
    
            public List<FileSystemLocationSnapshot> pop() {
                List<FileSystemLocationSnapshot> popped = stack.pollLast();
                if (popped == null) {
                    throw new IllegalStateException("Stack empty");
                }
                return popped;
            }
        }
    
        private static String toAbsolutePath(Collection<String> parents, String fileName) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jan 26 15:45:55 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_interval.go

    // source can change over time - i.e. for watchCache circular
    // buffer. When the circular buffer is full and an event needs
    // to be popped off, watchCache::startIndex is incremented. In
    // this case, an interval tracking that popped event is valid
    // only if it has already been copied to its internal buffer.
    // However, for efficiency we perform that lazily and we mark
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 09:20:10 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  8. pkg/scheduler/internal/queue/scheduling_queue_test.go

    	// Simulate a pod being popped by the scheduler,
    	// At this time, unschedulable pod should be popped.
    	p1, err := q.Pop(logger)
    	if err != nil {
    		t.Errorf("Error while popping the head of the queue: %v", err)
    	}
    	if p1.Pod != unschedulablePod {
    		t.Errorf("Expected that test-pod-unscheduled was popped, got %v", p1.Pod.Name)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
  9. src/go/ast/commentmap.go

    	s.pop(n.Pos())
    	*s = append((*s), n)
    }
    
    // pop pops all nodes that appear lexically before pos
    // (i.e., whose lexical extent has ended before or at pos).
    // It returns the last node popped.
    func (s *nodeStack) pop(pos token.Pos) (top Node) {
    	i := len(*s)
    	for i > 0 && (*s)[i-1].End() <= pos {
    		top = (*s)[i-1]
    		i--
    	}
    	*s = (*s)[0:i]
    	return top
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  10. pkg/scheduler/internal/queue/scheduling_queue.go

    	// are popped from this heap before the scheduler looks at activeQ
    	podBackoffQ *heap.Heap
    	// unschedulablePods holds pods that have been tried and determined unschedulable.
    	unschedulablePods *UnschedulablePods
    	// schedulingCycle represents sequence number of scheduling cycle and is incremented
    	// when a pod is popped.
    	schedulingCycle int64
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
Back to top