- Thread-safe push and fetch.
- Use stream operators to push (<<) and fetch (>>) items.
- Value type must be default constructible.
- Blocking (forever waiting to fetch).
- Range-based for loop supported.
- Close to prevent pushing and stop waiting to fetch.
- Integrates well with STL algorithms in some cases. Eg: std::move(ch.begin(), ch.end(), ...).
- Tested with GCC, Clang, and MSVC.
- C++11 or newer
Copy the include directory to your project and add it to your include path. Or see CMakeLists.txt from the CMake project example .
#include <cassert>
#include <msd/channel.hpp>
int main() {
msd::channel<int> chan; // unbuffered
int in = 1;
int out = 0;
// Send to channel
chan << in;
// Read from channel
chan >> out;
assert(out == 1);
}#include <msd/channel.hpp>
int main() {
msd::channel<int> chan{2}; // buffered
// Send to channel
chan << 1;
chan << 2;
chan << 3; // blocking because capacity is 2 (and no one reads from channel)
}#include <msd/channel.hpp>
int main() {
msd::channel<int> chan{2}; // buffered
int in = 1;
int out = 0;
// Send to channel
chan << in;
chan << in;
// Read from channel
chan >> out;
chan >> out;
chan >> out; // blocking because channel is empty (and no one writes on it)
}#include <iostream>
#include <msd/channel.hpp>
int main() {
msd::channel<int> chan;
int in1 = 1;
int in2 = 2;
chan << in1 << in2;
for (const auto out : chan) { // blocking: forever waiting for channel items
std::cout << out << '\n';
}
}See examples.
Developed with CLion