Remove thread_local_state
This commit is contained in:
@@ -18,8 +18,6 @@ use sync::{Arc, Mutex, MutexGuard};
|
|||||||
use sys::stdio;
|
use sys::stdio;
|
||||||
use sys_common::remutex::{ReentrantMutex, ReentrantMutexGuard};
|
use sys_common::remutex::{ReentrantMutex, ReentrantMutexGuard};
|
||||||
use thread::LocalKey;
|
use thread::LocalKey;
|
||||||
#[allow(deprecated)]
|
|
||||||
use thread::LocalKeyState;
|
|
||||||
|
|
||||||
/// Stdout used by print! and println! macros
|
/// Stdout used by print! and println! macros
|
||||||
thread_local! {
|
thread_local! {
|
||||||
@@ -670,25 +668,26 @@ pub fn set_print(sink: Option<Box<Write + Send>>) -> Option<Box<Write + Send>> {
|
|||||||
/// thread, it will just fall back to the global stream.
|
/// thread, it will just fall back to the global stream.
|
||||||
///
|
///
|
||||||
/// However, if the actual I/O causes an error, this function does panic.
|
/// However, if the actual I/O causes an error, this function does panic.
|
||||||
#[allow(deprecated)]
|
fn print_to<T>(
|
||||||
fn print_to<T>(args: fmt::Arguments,
|
args: fmt::Arguments,
|
||||||
local_s: &'static LocalKey<RefCell<Option<Box<Write+Send>>>>,
|
local_s: &'static LocalKey<RefCell<Option<Box<Write+Send>>>>,
|
||||||
global_s: fn() -> T,
|
global_s: fn() -> T,
|
||||||
label: &str) where T: Write {
|
label: &str,
|
||||||
let result = match local_s.state() {
|
)
|
||||||
LocalKeyState::Uninitialized |
|
where
|
||||||
LocalKeyState::Destroyed => global_s().write_fmt(args),
|
T: Write,
|
||||||
LocalKeyState::Valid => {
|
{
|
||||||
local_s.with(|s| {
|
let result = local_s.try_with(|s| {
|
||||||
if let Ok(mut borrowed) = s.try_borrow_mut() {
|
if let Ok(mut borrowed) = s.try_borrow_mut() {
|
||||||
if let Some(w) = borrowed.as_mut() {
|
if let Some(w) = borrowed.as_mut() {
|
||||||
return w.write_fmt(args);
|
return w.write_fmt(args);
|
||||||
}
|
}
|
||||||
}
|
|
||||||
global_s().write_fmt(args)
|
|
||||||
})
|
|
||||||
}
|
}
|
||||||
};
|
global_s().write_fmt(args)
|
||||||
|
}).unwrap_or_else(|_| {
|
||||||
|
global_s().write_fmt(args)
|
||||||
|
});
|
||||||
|
|
||||||
if let Err(e) = result {
|
if let Err(e) = result {
|
||||||
panic!("failed printing to {}: {}", label, e);
|
panic!("failed printing to {}: {}", label, e);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -195,45 +195,6 @@ macro_rules! __thread_local_inner {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Indicator of the state of a thread local storage key.
|
|
||||||
#[unstable(feature = "thread_local_state",
|
|
||||||
reason = "state querying was recently added",
|
|
||||||
issue = "27716")]
|
|
||||||
#[rustc_deprecated(since = "1.26.0", reason = "use `LocalKey::try_with` instead")]
|
|
||||||
#[derive(Debug, Eq, PartialEq, Copy, Clone)]
|
|
||||||
pub enum LocalKeyState {
|
|
||||||
/// All keys are in this state whenever a thread starts. Keys will
|
|
||||||
/// transition to the `Valid` state once the first call to [`with`] happens
|
|
||||||
/// and the initialization expression succeeds.
|
|
||||||
///
|
|
||||||
/// Keys in the `Uninitialized` state will yield a reference to the closure
|
|
||||||
/// passed to [`with`] so long as the initialization routine does not panic.
|
|
||||||
///
|
|
||||||
/// [`with`]: ../../std/thread/struct.LocalKey.html#method.with
|
|
||||||
Uninitialized,
|
|
||||||
|
|
||||||
/// Once a key has been accessed successfully, it will enter the `Valid`
|
|
||||||
/// state. Keys in the `Valid` state will remain so until the thread exits,
|
|
||||||
/// at which point the destructor will be run and the key will enter the
|
|
||||||
/// `Destroyed` state.
|
|
||||||
///
|
|
||||||
/// Keys in the `Valid` state will be guaranteed to yield a reference to the
|
|
||||||
/// closure passed to [`with`].
|
|
||||||
///
|
|
||||||
/// [`with`]: ../../std/thread/struct.LocalKey.html#method.with
|
|
||||||
Valid,
|
|
||||||
|
|
||||||
/// When a thread exits, the destructors for keys will be run (if
|
|
||||||
/// necessary). While a destructor is running, and possibly after a
|
|
||||||
/// destructor has run, a key is in the `Destroyed` state.
|
|
||||||
///
|
|
||||||
/// Keys in the `Destroyed` states will trigger a panic when accessed via
|
|
||||||
/// [`with`].
|
|
||||||
///
|
|
||||||
/// [`with`]: ../../std/thread/struct.LocalKey.html#method.with
|
|
||||||
Destroyed,
|
|
||||||
}
|
|
||||||
|
|
||||||
/// An error returned by [`LocalKey::try_with`](struct.LocalKey.html#method.try_with).
|
/// An error returned by [`LocalKey::try_with`](struct.LocalKey.html#method.try_with).
|
||||||
#[stable(feature = "thread_local_try_with", since = "1.26.0")]
|
#[stable(feature = "thread_local_try_with", since = "1.26.0")]
|
||||||
pub struct AccessError {
|
pub struct AccessError {
|
||||||
@@ -307,51 +268,6 @@ impl<T: 'static> LocalKey<T> {
|
|||||||
(*ptr).as_ref().unwrap()
|
(*ptr).as_ref().unwrap()
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Query the current state of this key.
|
|
||||||
///
|
|
||||||
/// A key is initially in the `Uninitialized` state whenever a thread
|
|
||||||
/// starts. It will remain in this state up until the first call to [`with`]
|
|
||||||
/// within a thread has run the initialization expression successfully.
|
|
||||||
///
|
|
||||||
/// Once the initialization expression succeeds, the key transitions to the
|
|
||||||
/// `Valid` state which will guarantee that future calls to [`with`] will
|
|
||||||
/// succeed within the thread. Some keys might skip the `Uninitialized`
|
|
||||||
/// state altogether and start in the `Valid` state as an optimization
|
|
||||||
/// (e.g. keys initialized with a constant expression), but no guarantees
|
|
||||||
/// are made.
|
|
||||||
///
|
|
||||||
/// When a thread exits, each key will be destroyed in turn, and as keys are
|
|
||||||
/// destroyed they will enter the `Destroyed` state just before the
|
|
||||||
/// destructor starts to run. Keys may remain in the `Destroyed` state after
|
|
||||||
/// destruction has completed. Keys without destructors (e.g. with types
|
|
||||||
/// that are [`Copy`]), may never enter the `Destroyed` state.
|
|
||||||
///
|
|
||||||
/// Keys in the `Uninitialized` state can be accessed so long as the
|
|
||||||
/// initialization does not panic. Keys in the `Valid` state are guaranteed
|
|
||||||
/// to be able to be accessed. Keys in the `Destroyed` state will panic on
|
|
||||||
/// any call to [`with`].
|
|
||||||
///
|
|
||||||
/// [`with`]: ../../std/thread/struct.LocalKey.html#method.with
|
|
||||||
/// [`Copy`]: ../../std/marker/trait.Copy.html
|
|
||||||
#[unstable(feature = "thread_local_state",
|
|
||||||
reason = "state querying was recently added",
|
|
||||||
issue = "27716")]
|
|
||||||
#[rustc_deprecated(since = "1.26.0", reason = "use `LocalKey::try_with` instead")]
|
|
||||||
#[allow(deprecated)]
|
|
||||||
pub fn state(&'static self) -> LocalKeyState {
|
|
||||||
unsafe {
|
|
||||||
match (self.inner)() {
|
|
||||||
Some(cell) => {
|
|
||||||
match *cell.get() {
|
|
||||||
Some(..) => LocalKeyState::Valid,
|
|
||||||
None => LocalKeyState::Uninitialized,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
None => LocalKeyState::Destroyed,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/// Acquires a reference to the value in this TLS key.
|
/// Acquires a reference to the value in this TLS key.
|
||||||
///
|
///
|
||||||
/// This will lazily initialize the value if this thread has not referenced
|
/// This will lazily initialize the value if this thread has not referenced
|
||||||
@@ -527,8 +443,6 @@ pub mod os {
|
|||||||
mod tests {
|
mod tests {
|
||||||
use sync::mpsc::{channel, Sender};
|
use sync::mpsc::{channel, Sender};
|
||||||
use cell::{Cell, UnsafeCell};
|
use cell::{Cell, UnsafeCell};
|
||||||
#[allow(deprecated)]
|
|
||||||
use super::LocalKeyState;
|
|
||||||
use thread;
|
use thread;
|
||||||
|
|
||||||
struct Foo(Sender<()>);
|
struct Foo(Sender<()>);
|
||||||
@@ -563,26 +477,21 @@ mod tests {
|
|||||||
}
|
}
|
||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
#[allow(deprecated)]
|
|
||||||
fn states() {
|
fn states() {
|
||||||
struct Foo;
|
struct Foo;
|
||||||
impl Drop for Foo {
|
impl Drop for Foo {
|
||||||
fn drop(&mut self) {
|
fn drop(&mut self) {
|
||||||
assert!(FOO.state() == LocalKeyState::Destroyed);
|
assert!(FOO.try_with(|_| ()).is_err());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
fn foo() -> Foo {
|
fn foo() -> Foo {
|
||||||
assert!(FOO.state() == LocalKeyState::Uninitialized);
|
assert!(FOO.try_with(|_| ()).is_err());
|
||||||
Foo
|
Foo
|
||||||
}
|
}
|
||||||
thread_local!(static FOO: Foo = foo());
|
thread_local!(static FOO: Foo = foo());
|
||||||
|
|
||||||
thread::spawn(|| {
|
thread::spawn(|| {
|
||||||
assert!(FOO.state() == LocalKeyState::Uninitialized);
|
assert!(FOO.try_with(|_| ()).is_ok());
|
||||||
FOO.with(|_| {
|
|
||||||
assert!(FOO.state() == LocalKeyState::Valid);
|
|
||||||
});
|
|
||||||
assert!(FOO.state() == LocalKeyState::Valid);
|
|
||||||
}).join().ok().unwrap();
|
}).join().ok().unwrap();
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -601,7 +510,6 @@ mod tests {
|
|||||||
}
|
}
|
||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
#[allow(deprecated)]
|
|
||||||
fn circular() {
|
fn circular() {
|
||||||
struct S1;
|
struct S1;
|
||||||
struct S2;
|
struct S2;
|
||||||
@@ -612,8 +520,7 @@ mod tests {
|
|||||||
impl Drop for S1 {
|
impl Drop for S1 {
|
||||||
fn drop(&mut self) {
|
fn drop(&mut self) {
|
||||||
unsafe {
|
unsafe {
|
||||||
HITS += 1;
|
if K2.try_with(|_| ()).is_err() {
|
||||||
if K2.state() == LocalKeyState::Destroyed {
|
|
||||||
assert_eq!(HITS, 3);
|
assert_eq!(HITS, 3);
|
||||||
} else {
|
} else {
|
||||||
if HITS == 1 {
|
if HITS == 1 {
|
||||||
@@ -629,7 +536,7 @@ mod tests {
|
|||||||
fn drop(&mut self) {
|
fn drop(&mut self) {
|
||||||
unsafe {
|
unsafe {
|
||||||
HITS += 1;
|
HITS += 1;
|
||||||
assert!(K1.state() != LocalKeyState::Destroyed);
|
assert!(K1.try_with(|_| ()).is_ok());
|
||||||
assert_eq!(HITS, 2);
|
assert_eq!(HITS, 2);
|
||||||
K1.with(|s| *s.get() = Some(S1));
|
K1.with(|s| *s.get() = Some(S1));
|
||||||
}
|
}
|
||||||
@@ -642,14 +549,13 @@ mod tests {
|
|||||||
}
|
}
|
||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
#[allow(deprecated)]
|
|
||||||
fn self_referential() {
|
fn self_referential() {
|
||||||
struct S1;
|
struct S1;
|
||||||
thread_local!(static K1: UnsafeCell<Option<S1>> = UnsafeCell::new(None));
|
thread_local!(static K1: UnsafeCell<Option<S1>> = UnsafeCell::new(None));
|
||||||
|
|
||||||
impl Drop for S1 {
|
impl Drop for S1 {
|
||||||
fn drop(&mut self) {
|
fn drop(&mut self) {
|
||||||
assert!(K1.state() == LocalKeyState::Destroyed);
|
assert!(K1.try_with(|_| ()).is_err());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -664,7 +570,6 @@ mod tests {
|
|||||||
// test on macOS.
|
// test on macOS.
|
||||||
#[test]
|
#[test]
|
||||||
#[cfg_attr(target_os = "macos", ignore)]
|
#[cfg_attr(target_os = "macos", ignore)]
|
||||||
#[allow(deprecated)]
|
|
||||||
fn dtors_in_dtors_in_dtors() {
|
fn dtors_in_dtors_in_dtors() {
|
||||||
struct S1(Sender<()>);
|
struct S1(Sender<()>);
|
||||||
thread_local!(static K1: UnsafeCell<Option<S1>> = UnsafeCell::new(None));
|
thread_local!(static K1: UnsafeCell<Option<S1>> = UnsafeCell::new(None));
|
||||||
@@ -674,9 +579,7 @@ mod tests {
|
|||||||
fn drop(&mut self) {
|
fn drop(&mut self) {
|
||||||
let S1(ref tx) = *self;
|
let S1(ref tx) = *self;
|
||||||
unsafe {
|
unsafe {
|
||||||
if K2.state() != LocalKeyState::Destroyed {
|
let _ = K2.try_with(|s| *s.get() = Some(Foo(tx.clone())));
|
||||||
K2.with(|s| *s.get() = Some(Foo(tx.clone())));
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -192,9 +192,6 @@ use time::Duration;
|
|||||||
|
|
||||||
#[stable(feature = "rust1", since = "1.0.0")]
|
#[stable(feature = "rust1", since = "1.0.0")]
|
||||||
pub use self::local::{LocalKey, AccessError};
|
pub use self::local::{LocalKey, AccessError};
|
||||||
#[stable(feature = "rust1", since = "1.0.0")]
|
|
||||||
#[allow(deprecated)]
|
|
||||||
pub use self::local::LocalKeyState;
|
|
||||||
|
|
||||||
// The types used by the thread_local! macro to access TLS keys. Note that there
|
// The types used by the thread_local! macro to access TLS keys. Note that there
|
||||||
// are two types, the "OS" type and the "fast" type. The OS thread local key
|
// are two types, the "OS" type and the "fast" type. The OS thread local key
|
||||||
|
|||||||
Reference in New Issue
Block a user