Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 18 of 18 for PushBack (0.15 sec)

  1. src/cmd/vendor/golang.org/x/sync/semaphore/semaphore.go

    		// Don't make other Acquire calls block on one that's doomed to fail.
    		s.mu.Unlock()
    		<-done
    		return ctx.Err()
    	}
    
    	ready := make(chan struct{})
    	w := waiter{n: n, ready: ready}
    	elem := s.waiters.PushBack(w)
    	s.mu.Unlock()
    
    	select {
    	case <-done:
    		s.mu.Lock()
    		select {
    		case <-ready:
    			// Acquired the semaphore after we were canceled.
    			// Pretend we didn't and put the tokens back.
    			s.cur -= n
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 03 02:38:00 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  2. src/net/http/transport.go

    	tail    []*wantConn
    }
    
    // len returns the number of items in the queue.
    func (q *wantConnQueue) len() int {
    	return len(q.head) - q.headPos + len(q.tail)
    }
    
    // pushBack adds w to the back of the queue.
    func (q *wantConnQueue) pushBack(w *wantConn) {
    	q.tail = append(q.tail, w)
    }
    
    // popFront removes and returns the wantConn at the front of the queue.
    func (q *wantConnQueue) popFront() *wantConn {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 91K bytes
    - Viewed (0)
  3. src/runtime/mgcmark.go

    	// lock.
    	if atomic.Load(&gcBlackenEnabled) == 0 {
    		unlock(&work.assistQueue.lock)
    		return true
    	}
    
    	gp := getg()
    	oldList := work.assistQueue.q
    	work.assistQueue.q.pushBack(gp)
    
    	// Recheck for background credit now that this G is in
    	// the queue, but can still back out. This avoids a
    	// race in case background marking has flushed more
    	// credit since we checked above.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 18 21:25:11 UTC 2024
    - 52.5K bytes
    - Viewed (0)
  4. pkg/scheduler/internal/queue/scheduling_queue.go

    	}
    	pInfo := obj.(*framework.QueuedPodInfo)
    	pInfo.Attempts++
    	p.schedulingCycle++
    	// In flight, no concurrent events yet.
    	if p.isSchedulingQueueHintEnabled {
    		p.inFlightPods[pInfo.Pod.UID] = p.inFlightEvents.PushBack(pInfo.Pod)
    	}
    
    	// Update metrics and reset the set of unschedulable plugins for the next attempt.
    	for plugin := range pInfo.UnschedulablePlugins.Union(pInfo.PendingPlugins) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
  5. src/runtime/proc.go

    }
    
    // push adds gp to the head of q.
    func (q *gQueue) push(gp *g) {
    	gp.schedlink = q.head
    	q.head.set(gp)
    	if q.tail == 0 {
    		q.tail.set(gp)
    	}
    }
    
    // pushBack adds gp to the tail of q.
    func (q *gQueue) pushBack(gp *g) {
    	gp.schedlink = 0
    	if q.tail != 0 {
    		q.tail.ptr().schedlink.set(gp)
    	} else {
    		q.head.set(gp)
    	}
    	q.tail.set(gp)
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 207.5K bytes
    - Viewed (0)
  6. src/net/http/h2_bundle.go

    		return http2errClientDisconnected
    	}
    }
    
    // writeFrame schedules a frame to write and sends it if there's nothing
    // already being written.
    //
    // There is no pushback here (the serve goroutine never blocks). It's
    // the http.Handlers that block, waiting for their previous frames to
    // make it onto the wire
    //
    // If you're not on the serve goroutine, use writeFrameFromHandler instead.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 364.1K bytes
    - Viewed (0)
  7. src/cmd/vendor/golang.org/x/tools/internal/stdlib/manifest.go

    		{"(*List).Len", Method, 0},
    		{"(*List).MoveAfter", Method, 2},
    		{"(*List).MoveBefore", Method, 2},
    		{"(*List).MoveToBack", Method, 0},
    		{"(*List).MoveToFront", Method, 0},
    		{"(*List).PushBack", Method, 0},
    		{"(*List).PushBackList", Method, 0},
    		{"(*List).PushFront", Method, 0},
    		{"(*List).PushFrontList", Method, 0},
    		{"(*List).Remove", Method, 0},
    		{"Element", Type, 0},
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 02:20:05 UTC 2024
    - 534.2K bytes
    - Viewed (0)
  8. api/go1.txt

    pkg container/list, method (*List) Len() int
    pkg container/list, method (*List) MoveToBack(*Element)
    pkg container/list, method (*List) MoveToFront(*Element)
    pkg container/list, method (*List) PushBack(interface{}) *Element
    pkg container/list, method (*List) PushBackList(*List)
    pkg container/list, method (*List) PushFront(interface{}) *Element
    pkg container/list, method (*List) PushFrontList(*List)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
Back to top