Keyboard shortcuts

Press ← or → to navigate between chapters

Press S or / to search in the book

Press ? to show this help

Press Esc to hide this help

Arc

Arc<T> позволяет разделяемое владение только для чтения через Arc::clone:

// Copyright 2024 Google LLC
// SPDX-License-Identifier: Apache-2.0

use std::sync::Arc;
use std::thread;

/// Структура, которая выводит, какой поток её освобождает.
#[derive(Debug)]
struct WhereDropped(Vec<i32>);

impl Drop for WhereDropped {
    fn drop(&mut self) {
        println!("Dropped by {:?}", thread::current().id())
    }
}

fn main() {
    let v = Arc::new(WhereDropped(vec![10, 20, 30]));
    let mut handles = Vec::new();
    for i in 0..5 {
        let v = Arc::clone(&v);
        handles.push(thread::spawn(move || {
            // Спим от 0 до 500 мс.
            std::thread::sleep(std::time::Duration::from_millis(500 - i * 100));
            let thread_id = thread::current().id();
            println!("{thread_id:?}: {v:?}");
        }));
    }

    // Теперь только порождённые потоки будут держать клоны `v`.
    drop(v);

    // Когда последний порождённый поток завершится, он освободит содержимое `v`.
    handles.into_iter().for_each(|h| h.join().unwrap());
}
This slide should take about 5 minutes.
  • Arc расшифровывается как «Atomic Reference Counted» — потокобезопасная версия Rc, которая использует атомарные операции.
  • Arc<T> реализует Clone независимо от того, реализует ли его T. Он реализует Send и Sync тогда и только тогда, когда T реализует оба этих трейта.
  • Arc::clone() имеет стоимость выполнения атомарных операций, но после этого использование T ничего не стоит.
  • Остерегайтесь циклов ссылок: Arc не использует сборщик мусора, чтобы их обнаруживать.
    • Здесь может помочь std::sync::Weak.