libsync 0.3.0

A channels library
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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150

#![doc = include_str!("../README.md")] 

#![cfg_attr(docsrs, feature(doc_auto_cfg))]

//#[cfg(all(feature="crossbeam", feature="tokio"))]
#[cfg(feature="crossbeam")]
pub mod crossbeam;

#[cfg(feature="std")]
pub mod std;

mod results;

pub use results::*;

mod shared_details;

pub use shared_details::*;

mod bounded_shared_details;

pub use bounded_shared_details::*;

/*
#[cfg(feature="count_waiting_senders_and_receivers")]
mod scoped_incrementer;

#[cfg(feature="count_waiting_senders_and_receivers")]
pub use scoped_incrementer::*;
*/

#[cfg(feature="tokio")]
pub mod tokio_helpers;

mod waker_permit_queue;

pub use waker_permit_queue::*;

#[cfg(test)]
mod waker_permit_queue_tests;

//#[cfg(test)]
//pub use waker_permit_queue_tests::*;

//Disabled

//mod waker_queue;

//pub use waker_queue::*;

#[cfg(feature="scc")]
pub mod scc;

mod channel_shared_details;

pub use channel_shared_details::*;

//Disabled

/*
mod single_waker;

pub use single_waker::*;

#[cfg(test)]
mod single_waker_tests;

*/

mod queued_waker;

pub use queued_waker::*;

mod limited_waker_permit_queue;

pub use limited_waker_permit_queue::*;

#[cfg(test)]
mod limited_waker_permit_queue_tests;

//#[cfg(test)]
//mod limited_waker_permit_queue_tests;

//Disabled

/*

mod single_waker_multi_permit;

pub use single_waker_multi_permit::*;

#[cfg(test)]
mod single_waker_multi_permit_tests;

*/

//Re-enabled in v0.4.0?

#[cfg(feature="crossbeam-queue")]
pub mod crossbeam_queue;

//Disabled

/*

mod limited_single_waker_multi_permit;

pub use limited_single_waker_multi_permit::*;

#[cfg(test)]
mod limited_single_waker_multi_permit_tests;

*/

//Re-enabled in v0.4.0?

///
/// The preferred type of mutex to be used for synchronisation.
/// 
#[cfg(feature="use_std_sync")]
pub type PreferredMutexType<T> = ::std::sync::Mutex<T>;

///
/// The preferred type of mutex to be used for synchronisation.
/// 
#[cfg(feature="use_parking_lot_sync")]
pub type PreferredMutexType<T> = parking_lot::Mutex<T>;

///
/// The preferred type of mutex to be used for synchronisation.
/// 
#[cfg(feature="use_parking_lot_fair_sync")]
pub type PreferredMutexType<T> = parking_lot::FairMutex<T>;

/*
pub fn add(left: usize, right: usize) -> usize {
    left + right
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn it_works() {
        let result = add(2, 2);
        assert_eq!(result, 4);
    }
}
*/