Home
last modified time | relevance | path

Searched refs:ArrayQueue (Results 1 – 9 of 9) sorted by relevance

/external/rust/android-crates-io/crates/crossbeam-queue/tests/
Darray_queue.rs3 use crossbeam_queue::ArrayQueue;
9 let q = ArrayQueue::new(1); in smoke()
22 let q = ArrayQueue::<i32>::new(i); in capacity()
30 let _ = ArrayQueue::<i32>::new(0); in zero_capacity()
35 let q = ArrayQueue::new(2); in len_empty_full()
72 let q = ArrayQueue::new(CAP); in len()
131 let q = ArrayQueue::new(3); in spsc()
163 let q = ArrayQueue::<usize>::new(3); in spsc_ring_buffer()
204 let q = ArrayQueue::<usize>::new(3); in mpmc()
244 let q = ArrayQueue::<usize>::new(3); in mpmc_ring_buffer()
[all …]
/external/rust/android-crates-io/crates/crossbeam-queue/
DCHANGELOG.md12 - Implement `UnwindSafe` and `RefUnwindSafe` for `ArrayQueue` and `SegQueue`. (#1053)
13 - Optimize `Drop` implementation of `ArrayQueue`. (#1057)
37 - Add `ArrayQueue::force_push`. (#789)
41 - Implement `IntoIterator` for `ArrayQueue` and `SegQueue`. (#772)
45 - Fix stacked borrows violation in `ArrayQueue` when `-Zmiri-tag-raw-pointers` is enabled. (#763)
88 - Initial version with `ArrayQueue` and `SegQueue`.
DREADME.md17 * [`ArrayQueue`], a bounded MPMC queue that allocates a fixed-capacity buffer on construction.
23 [`ArrayQueue`]: https://docs.rs/crossbeam-queue/*/crossbeam_queue/struct.ArrayQueue.html
/external/rust/android-crates-io/crates/crossbeam-queue/src/
Darray_queue.rs50 pub struct ArrayQueue<T> { struct
77 unsafe impl<T: Send> Sync for ArrayQueue<T> {} argument
78 unsafe impl<T: Send> Send for ArrayQueue<T> {} implementation
80 impl<T> UnwindSafe for ArrayQueue<T> {} implementation
81 impl<T> RefUnwindSafe for ArrayQueue<T> {} implementation
83 impl<T> ArrayQueue<T> { impl
97 pub fn new(cap: usize) -> ArrayQueue<T> { in new()
120 ArrayQueue { in new()
448 impl<T> Drop for ArrayQueue<T> { implementation
487 impl<T> fmt::Debug for ArrayQueue<T> { implementation
[all …]
Dlib.rs34 pub use crate::{array_queue::ArrayQueue, seg_queue::SegQueue};
/external/rust/android-crates-io/crates/vulkano/src/command_buffer/
Dallocator.rs27 use crossbeam_queue::ArrayQueue;
234 let reserve = Arc::new(ArrayQueue::new(MAX_POOLS)); in allocate()
305 reserve: Arc<ArrayQueue<PoolInner>>,
332 reserve: Arc<ArrayQueue<PoolInner>>,
340 primary_pool: Option<ArrayQueue<CommandPoolAlloc>>,
342 secondary_pool: Option<ArrayQueue<CommandPoolAlloc>>,
353 reserve: Arc<ArrayQueue<PoolInner>>, in new()
371 let pool = ArrayQueue::new(create_info.primary_buffer_count); in new()
387 let pool = ArrayQueue::new(create_info.secondary_buffer_count); in new()
/external/rust/android-crates-io/crates/vulkano/src/descriptor_set/
Dallocator.rs32 use crossbeam_queue::ArrayQueue;
255 reserve: ArrayQueue<UnsafeDescriptorSet>,
280 let reserve = ArrayQueue::new(set_count); in new()
316 reserve: Arc<ArrayQueue<DescriptorPool>>,
325 let reserve = Arc::new(ArrayQueue::new(MAX_POOLS)); in new()
388 reserve: Arc<ArrayQueue<DescriptorPool>>,
394 reserve: Arc<ArrayQueue<DescriptorPool>>, in new()
/external/rust/android-crates-io/crates/vulkano/src/buffer/
Dallocator.rs27 use crossbeam_queue::ArrayQueue;
286 reserve: Option<Arc<ArrayQueue<Arc<Buffer>>>>,
339 self.reserve = Some(Arc::new(ArrayQueue::new(MAX_ARENAS))); in next_arena()
381 reserve: Arc<ArrayQueue<Arc<Buffer>>>,
/external/rust/android-crates-io/crates/vulkano/src/memory/allocator/
Dsuballocator.rs27 use crossbeam_queue::ArrayQueue;
2088 free_list: ArrayQueue<DeviceSize>,
2113 let free_list = ArrayQueue::new(block_count as usize); in new()
2677 let allocs = ArrayQueue::new((ALLOCATIONS_PER_THREAD * THREADS) as usize); in free_list_allocator_capacity()