add async <--> blocking "bridge" Fns to async channel

Cargo.toml

@@ -1,8 +1,5 @@
 [workspace]
-members = [
-    ".",
-    "bench"
-]
+members = [".", "bench"]
 
 [package]
 name = "thingbuf"
@@ -31,13 +28,22 @@ pin-project = "1"
 parking_lot = { version = "0.12", optional = true, default-features = false }
 
 [dev-dependencies]
-tokio = { version = "1.14.0", features = ["rt", "rt-multi-thread", "macros", "sync"] }
+tokio = { version = "1.14.0", features = [
+  "rt",
+  "rt-multi-thread",
+  "macros",
+  "sync",
+  "time",
+] }
 # So that we can use `poll_fn` in tests.
 futures-util = { version = "0.3", default-features = false }
 
 [target.'cfg(loom)'.dev-dependencies]
 loom = { version = "0.5.6", features = ["checkpoint", "futures"] }
-tracing-subscriber = { version = "0.3", default-features = false, features = ["std", "fmt"] }
+tracing-subscriber = { version = "0.3", default-features = false, features = [
+  "std",
+  "fmt",
+] }
 tracing = { version = "0.1", default-features = false, features = ["std"] }
 
 # Custom profile for Loom tests: enable release optimizations so that the loom
@@ -53,3 +59,10 @@ loom = { git = "https://github.com/tokio-rs/loom", rev = "a93bf2390e0fcfdb7c5899
 [package.metadata.docs.rs]
 all-features = true
 rustdoc-args = ["--cfg", "docsrs"]
+
+[lints.rust]
+unexpected_cfgs = { level = "warn", check-cfg = [
+  'cfg(loom)',
+  'cfg(thingbuf_trace)',
+  'cfg(ci_skip_slow_models)',
+] }

bin/loom

@@ -17,15 +17,16 @@ cd "$(dirname "$0")"/..
 TESTCMD=(test)
 
 # if cargo nextest is installed, use it instead!
-if cargo list | grep -q "nextest"; then
-    TESTCMD=(nextest run --cargo-profile loom)
+if cargo --list | grep -q "nextest"; then
+  TESTCMD=(nextest run --cargo-profile loom)
 fi
 
 TESTCMD+=(--profile loom --lib)
 # pass through args
 TESTCMD+=(${@})
 
 RUSTFLAGS="--cfg loom ${RUSTFLAGS:-}" \
-    LOOM_LOG="${LOOM_LOG:-info}" \
-    LOOM_MAX_PREEMPTIONS="${LOOM_MAX_PREEMPTIONS:-2}" \
-    cargo ${TESTCMD[@]}
+  LOOM_LOG="${LOOM_LOG:-info}" \
+  LOOM_MAX_PREEMPTIONS="${LOOM_MAX_PREEMPTIONS:-2}" \
+  cargo ${TESTCMD[@]}
+

src/lib.rs

@@ -10,6 +10,8 @@ mod macros;
 mod loom;
 pub mod mpsc;
 pub mod recycling;
+#[cfg(feature = "std")]
+mod thread_waker;
 mod util;
 mod wait;
 

src/loom.rs

@@ -8,7 +8,7 @@ mod inner {
         pub use std::sync::atomic::Ordering;
     }
 
-    pub(crate) use loom::{cell, future, hint, sync, thread};
+    pub(crate) use loom::{cell, future, hint, sync, thread, thread_local};
     use std::{cell::RefCell, fmt::Write};
 
     pub(crate) mod model {
@@ -214,7 +214,7 @@ mod inner {
     pub(crate) use core::sync::atomic;
 
     #[cfg(feature = "std")]
-    pub use std::thread;
+    pub use std::{thread, thread_local};
 
     pub(crate) mod hint {
         #[inline(always)]