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.
- Здесь может помочь