Method new

src/thread_pool.rs:114–127

()

    /// seat (to ensure the `!Sync` bound is respected).
    pub sharers: [Sharer<JobRef>; 32],
    /// The stealing side of each seat's work-stealing queue.
    pub stealers: [Stealer<JobRef>; 32],
    /// A set of queues used for transmitting work that must be executed on a
    /// particular worker. Used for broadcasts and cross-thread nonsend worker
    /// wakeups.
    pub broadcasts: [SegQueue<JobRef>; 32],
    /// A binary semaphore for each seat, used for signaling.
    pub semaphores: [Semaphore; 32],
}

impl MemberData {
    fn new() -> MemberData {
        let sharers: [Sharer<JobRef>; 32] =
            array::from_fn(|_| Sharer::new(Worker::STEAL_QUEUE_CAPACITY));
        let stealers: [Stealer<JobRef>; 32] =
            array::from_fn(|i| sharers[i].stealer());
        let broadcasts = array::from_fn(|_| SegQueue::new());