- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 103 for pushHead (0.13 sec)
-
src/sync/export_test.go
return d } func (d *poolDequeue) PushHead(val any) bool { return d.pushHead(val) } func (d *poolDequeue) PopHead() (any, bool) { return d.popHead() } func (d *poolDequeue) PopTail() (any, bool) { return d.popTail() } func NewPoolChain() PoolDequeue { return new(poolChain) } func (c *poolChain) PushHead(val any) bool { c.pushHead(val) return true }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Nov 17 16:39:52 UTC 2023 - 1.2K bytes - Viewed (0) -
src/sync/poolqueue.go
const mask = 1<<dequeueBits - 1 return (uint64(head) << dequeueBits) | uint64(tail&mask) } // pushHead adds val at the head of the queue. It returns false if the // queue is full. It must only be called by a single producer. func (d *poolDequeue) pushHead(val any) bool { ptrs := d.headTail.Load() head, tail := d.unpack(ptrs) if (tail+uint32(len(d.vals)))&(1<<dequeueBits-1) == 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) -
src/sync/pool_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 8K bytes - Viewed (0) -
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) -
platforms/core-configuration/kotlin-dsl/src/main/kotlin/org/gradle/kotlin/dsl/resolver/ConcurrentGroupingQueue.kt
import java.util.concurrent.locks.ReentrantLock import kotlin.concurrent.withLock /** * A queue that gives priority to the most recently pushed element. */ internal class ConcurrentGroupingQueue<T>( /** * Predicate to check whether the given most recently pushed element (the receiver) * supersedes the given less recent element (the argument). *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Aug 02 08:06:49 UTC 2023 - 2.7K bytes - Viewed (0) -
.github/workflows/notify-on-rc-for-manual-test.yml
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 02 09:13:16 UTC 2024 - 1K bytes - Viewed (0) -
src/cmd/link/testdata/linkname/push.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 17:05:33 UTC 2024 - 426 bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/PushObserver.kt
* * As a stream ID is scoped to a single HTTP/2 connection, implementations which target multiple * connections should expect repetition of stream IDs. * * Return true to request cancellation of a pushed stream. Note that this does not guarantee * future frames won't arrive on the stream ID. */ interface PushObserver { /** * Describes the request that the server intends to push a response for. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.6K bytes - Viewed (0) -
src/runtime/mkpreempt.go
p("CALL ·asyncPreempt2(SB)") l.restore() p("MOVD %d(RSP), R30", l.stack) // sigctxt.pushCall has pushed LR (at interrupt) on stack, restore it p("MOVD -8(RSP), R29") // restore frame pointer p("MOVD (RSP), R27") // load PC to REGTMP p("ADD $%d, RSP", l.stack+16) // pop frame (including the space pushed by sigctxt.pushCall) p("JMP (R27)") } func genMIPS(_64bit bool) { mov := "MOVW"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Nov 20 17:19:36 UTC 2023 - 15.3K bytes - Viewed (0) -
src/cmd/link/testdata/linkname/p/p.go
// Copyright 2024 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package p import _ "unsafe" // f1 is pushed from main. // //go:linkname f1 func f1() // Push f2 to main. // //go:linkname f2 main.f2 func f2() {}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 17:05:33 UTC 2024 - 328 bytes - Viewed (0)