- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 50 for pushHead (0.67 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) -
releasenotes/notes/istiod-config-size-bytes.yaml
apiVersion: release-notes/v2 kind: feature area: traffic-management issue: - 31772 releaseNotes: - |
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 14 00:22:23 UTC 2021 - 208 bytes - Viewed (0) -
releasenotes/notes/36806.yaml
apiVersion: release-notes/v2 kind: bug-fix area: traffic-management issue: - 36805 releaseNotes: - | **Fixed** an issue that if duplicated cipher suites configured in Gateway, it will be pushed to Envoy configuration. With this fix, duplicated cipher
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 02 19:51:18 UTC 2022 - 302 bytes - Viewed (0)