Skip to content

Commit

Permalink
Auto merge of rust-lang#92553 - m-ou-se:thread-join-simplify, r=Mark-…
Browse files Browse the repository at this point in the history
…Simulacrum

Simpilfy thread::JoinInner.

`JoinInner`'s `native` field was an `Option`, but that's unnecessary.

Also, thanks to `Arc::get_mut`, there's no unsafety needed in `JoinInner::join()`.
  • Loading branch information
bors committed Jan 13, 2022
2 parents e916815 + a45b3ac commit 256721e
Showing 1 changed file with 9 additions and 9 deletions.
18 changes: 9 additions & 9 deletions library/std/src/thread/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -498,12 +498,12 @@ impl Builder {
// exist after the thread has terminated, which is signaled by `Thread::join`
// returning.
native: unsafe {
Some(imp::Thread::new(
imp::Thread::new(
stack_size,
mem::transmute::<Box<dyn FnOnce() + 'a>, Box<dyn FnOnce() + 'static>>(
Box::new(main),
),
)?)
)?
},
thread: my_thread,
packet: Packet(my_packet),
Expand Down Expand Up @@ -1261,15 +1261,15 @@ unsafe impl<T: Sync> Sync for Packet<T> {}

/// Inner representation for JoinHandle
struct JoinInner<T> {
native: Option<imp::Thread>,
native: imp::Thread,
thread: Thread,
packet: Packet<T>,
}

impl<T> JoinInner<T> {
fn join(&mut self) -> Result<T> {
self.native.take().unwrap().join();
unsafe { (*self.packet.0.get()).take().unwrap() }
fn join(mut self) -> Result<T> {
self.native.join();
Arc::get_mut(&mut self.packet.0).unwrap().get_mut().take().unwrap()
}
}

Expand Down Expand Up @@ -1400,7 +1400,7 @@ impl<T> JoinHandle<T> {
/// join_handle.join().expect("Couldn't join on the associated thread");
/// ```
#[stable(feature = "rust1", since = "1.0.0")]
pub fn join(mut self) -> Result<T> {
pub fn join(self) -> Result<T> {
self.0.join()
}

Expand All @@ -1416,13 +1416,13 @@ impl<T> JoinHandle<T> {

impl<T> AsInner<imp::Thread> for JoinHandle<T> {
fn as_inner(&self) -> &imp::Thread {
self.0.native.as_ref().unwrap()
&self.0.native
}
}

impl<T> IntoInner<imp::Thread> for JoinHandle<T> {
fn into_inner(self) -> imp::Thread {
self.0.native.unwrap()
self.0.native
}
}

Expand Down

0 comments on commit 256721e

Please sign in to comment.