Files
aho_corasick
atty
beef
bitflags
bstr
byteset
search
unicode
byteorder
cfg_if
clap
build
output
parse
util
clap_derive
derives
utils
codespan
codespan_reporting
crc_any
crypto_hash
csv
csv_core
debug_helper
filepath
fixed
fixed_macro
fixed_macro_impl
fixed_macro_types
fnv
foreign_types
foreign_types_shared
getrandom
glob
hashbrown
heck
hex
indexmap
itoa
lazy_static
libc
unix
linked_hash_map
linked_hash_set
logos
logos_derive
generator
graph
parser
lrl_test_compiler
config_binary
environment
mission_control
result
test_assembly
test_binary
test_descriptor
timeline
maplit
memchr
memoffset
once_cell
openssl
openssl_sys
os_str_bytes
paste
pest
iterators
unicode
pest_derive
pest_generator
pest_meta
phf
phf_generator
phf_macros
phf_shared
ppv_lite86
proc_macro2
proc_macro_error
proc_macro_error_attr
proc_macro_hack
quote
rand
distributions
rngs
seq
rand_chacha
rand_core
regex
regex_automata
regex_syntax
ast
hir
unicode_tables
remove_dir_all
ring
aead
gcm
arithmetic
digest
ec
curve25519
suite_b
io
rsa
rowan
rustc_hash
ryu
semver
semver_parser
serde
de
private
ser
serde_derive
serde_json
siphasher
smallvec
smawk
smol_str
spin
stable_deref_trait
strsim
syn
attr.rsawait.rsbigint.rsbuffer.rscustom_keyword.rscustom_punctuation.rsdata.rsderive.rsdiscouraged.rserror.rsexport.rsexpr.rsext.rsfile.rsgenerics.rsgroup.rsident.rsitem.rslib.rslifetime.rslit.rslookahead.rsmac.rsmacros.rsop.rsparse.rsparse_macro_input.rsparse_quote.rspat.rspath.rsprint.rspunctuated.rsreserved.rssealed.rsspan.rsspanned.rsstmt.rsthread.rstoken.rstt.rsty.rsverbatim.rswhitespace.rs
taplo
dom
formatter
parser
util
tempfile
termcolor
text_size
textwrap
wrap_algorithms
toml
triomphe
typenum
ucd_trie
unicode_linebreak
unicode_segmentation
unicode_width
unicode_xid
untrusted
utf8_ranges
vec_map
>
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41
use std::fmt::{self, Debug}; use std::thread::{self, ThreadId}; /// ThreadBound is a Sync-maker and Send-maker that allows accessing a value /// of type T only from the original thread on which the ThreadBound was /// constructed. pub struct ThreadBound<T> { value: T, thread_id: ThreadId, } unsafe impl<T> Sync for ThreadBound<T> {} // Send bound requires Copy, as otherwise Drop could run in the wrong place. unsafe impl<T: Copy> Send for ThreadBound<T> {} impl<T> ThreadBound<T> { pub fn new(value: T) -> Self { ThreadBound { value, thread_id: thread::current().id(), } } pub fn get(&self) -> Option<&T> { if thread::current().id() == self.thread_id { Some(&self.value) } else { None } } } impl<T: Debug> Debug for ThreadBound<T> { fn fmt(&self, formatter: &mut fmt::Formatter) -> fmt::Result { match self.get() { Some(value) => Debug::fmt(value, formatter), None => formatter.write_str("unknown"), } } }