Совместное использование объекта только для чтения между потоками в Rust? [Дубликат]

Поддержка потоков в стандартной библиотеке позволяет созданным потокам пережить поток, который их создал; это хорошая вещь! Однако, если вы должны передать ссылку на выделенную стекю переменную на один из этих потоков, нет гарантии, что переменная будет по-прежнему действительной к моменту выполнения потока. На других языках это позволит потоку получить доступ к недопустимой памяти, создавая кучу проблем с безопасностью памяти.

К счастью, мы не ограничиваемся стандартной библиотекой. По меньшей мере, два ящика обеспечивают потоки с ограниченной областью - потоки, которые гарантированно выходят до того, как закончится определенный охват. Они могут гарантировать, что переменные стека будут доступны для всей длительности потока:

• crossbeam
• scoped-threadpool

Есть также ящики, которые абстрагируют детали нижнего уровня «потоков», но позволяют достичь ваших целей:

Вот примеры каждого из них. Каждый пример порождает несколько потоков и мутирует локальный вектор на месте без блокировки, нет Arc и никакого клонирования. Обратите внимание, что мутация имеет вызов sleep, чтобы помочь проверить, что вызовы происходят параллельно.

Вы можете расширить примеры, чтобы поделиться ссылкой на любой тип, который реализует Sync , например Mutex или Atomic*. Однако использование [

scoped-threadpool

extern crate scoped_threadpool;
use scoped_threadpool::Pool;

use std::thread;
use std::time::Duration;

fn main() {
    let mut vec = vec![1, 2, 3, 4, 5];
    let mut pool = Pool::new(vec.len() as u32);

    pool.scoped(|scoped| {
        for e in &mut vec {
            scoped.execute(move || {
                thread::sleep(Duration::from_millis(1000));
                *e += 1;
            });
        }
    });

    println!("{:?}", vec);
}

crossbeam

extern crate crossbeam;

use std::thread;
use std::time::Duration;

fn main() {
    let mut vec = vec![1, 2, 3, 4, 5];

    crossbeam::scope(|scope| {
        for e in &mut vec {
            scope.spawn(move || {
                thread::sleep(Duration::from_millis(1000));
                *e += 1;
            });
        }
    });

    println!("{:?}", vec);
}

rayon

extern crate rayon;

use rayon::iter::{IntoParallelRefMutIterator, ParallelIterator};
use std::{thread, time::Duration};

fn main() {
    let mut vec = vec![1, 2, 3, 4, 5];

    vec.par_iter_mut().for_each(|e| {
        thread::sleep(Duration::from_millis(1000));
        *e += 1;
    });

    println!("{:?}", vec);
}

клиент должен подключить соединение в Arc, когда он является внутренним для библиотеки, что этот код распараллелен

Возможно, вы можете лучше скрыть свой параллелизм? Не могли бы вы принять регистратор и затем обернуть его в Arc / Mutex, прежде чем передавать его в свои потоки?