Fixed send and sync for mutex and rwlock

databendlabs · Sep 2, 2021 · 26028ef · 26028ef
1 parent cbd8a3c
commit 26028ef
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 7 deletions.
diff --git a/common/infallible/src/mutex.rs b/common/infallible/src/mutex.rs
@@ -19,11 +19,8 @@ use parking_lot::MutexGuard;
 #[derive(Debug)]
 pub struct Mutex<T>(ParkingMutex<T>);
 
-/// Mutex is Send
-unsafe impl<T> Send for Mutex<T> {}
-
-/// Mutex is Sync
-unsafe impl<T> Sync for Mutex<T> {}
+unsafe impl<T> Send for Mutex<T> where ParkingMutex<T>: Send {}
+unsafe impl<T> Sync for Mutex<T> where ParkingMutex<T>: Sync {}
 
 impl<T> Mutex<T> {
     /// creates mutex

diff --git a/common/infallible/src/rwlock.rs b/common/infallible/src/rwlock.rs
@@ -21,8 +21,8 @@ use parking_lot::RwLockWriteGuard;
 #[derive(Debug, Default)]
 pub struct RwLock<T>(ParkingRwLock<T>);
 
-unsafe impl<T> Send for RwLock<T> {}
-unsafe impl<T> Sync for RwLock<T> {}
+unsafe impl<T> Send for RwLock<T> where ParkingRwLock<T>: Send {}
+unsafe impl<T> Sync for RwLock<T> where ParkingRwLock<T>: Sync {}
 
 impl<T> RwLock<T> {
     /// creates a read-write lock