Home
last modified time | relevance | path

Searched refs:buffered_channel (Results 1 – 22 of 22) sorted by relevance

/third_party/boost/libs/fiber/doc/
Dbuffered_channel.qbk8 [section:buffered_channel Buffered Channel]
14 typedef boost::fibers::buffered_channel< int > channel_t;
37 Class `buffered_channel` supports range-for syntax:
39 typedef boost::fibers::buffered_channel< int > channel_t;
60 [template_heading buffered_channel]
62 #include <boost/fiber/buffered_channel.hpp>
68 class buffered_channel {
74 explicit buffered_channel( std::size_t capacity);
76 buffered_channel( buffered_channel const& other) = delete;
77 buffered_channel & operator=( buffered_channel const& other) = delete;
[all …]
Dwhen_any.qbk140 instead to use a [template_link buffered_channel]. We'll only need to enqueue
141 the first value, so we'll [member_link buffered_channel..close] it once we've
169 wait_first_value `wait_first_value()`]'s [template_link buffered_channel] to
179 `future<>` to [member_link buffered_channel..push] on the queue?
251 [member_link buffered_channel..pop] call would block forever.
357 to return `shared_ptr<buffered_channel<T>>`.
371 buffered_channel..close] the queue when done. But how do we do that? Each
373 [member_link buffered_channel..push] a value.
Dworker.qbk61 boost::fibers::buffered_channel<task> ch{1024};
Dfibers.qbk279 [include buffered_channel.qbk]
/third_party/boost/libs/fiber/test/
Dtest_buffered_channel_dispatch.cpp51 boost::fibers::buffered_channel< int > c( 0); in test_zero_wm()
59 boost::fibers::buffered_channel< int > c( 16); in test_push()
64 boost::fibers::buffered_channel< int > c( 16); in test_push_closed()
70 boost::fibers::buffered_channel< int > c( 2); in test_try_push()
75 boost::fibers::buffered_channel< int > c( 2); in test_try_push_closed()
82 boost::fibers::buffered_channel< int > c( 2); in test_try_push_full()
88 boost::fibers::buffered_channel< int > c( 2); in test_push_wait_for()
93 boost::fibers::buffered_channel< int > c( 2); in test_push_wait_for_closed()
99 boost::fibers::buffered_channel< int > c( 2); in test_push_wait_for_timeout()
105 boost::fibers::buffered_channel< int > c( 2); in test_push_wait_until()
[all …]
Dtest_buffered_channel_post.cpp51 boost::fibers::buffered_channel< int > c( 0); in test_zero_wm()
59 boost::fibers::buffered_channel< int > c( 16); in test_push()
64 boost::fibers::buffered_channel< int > c( 16); in test_push_closed()
70 boost::fibers::buffered_channel< int > c( 2); in test_try_push()
75 boost::fibers::buffered_channel< int > c( 2); in test_try_push_closed()
82 boost::fibers::buffered_channel< int > c( 2); in test_try_push_full()
88 boost::fibers::buffered_channel< int > c( 2); in test_push_wait_for()
93 boost::fibers::buffered_channel< int > c( 2); in test_push_wait_for_closed()
99 boost::fibers::buffered_channel< int > c( 2); in test_push_wait_for_timeout()
105 boost::fibers::buffered_channel< int > c( 2); in test_push_wait_until()
[all …]
/third_party/boost/boost/fiber/
Dbuffered_channel.hpp35 class buffered_channel { class
65 explicit buffered_channel( std::size_t capacity) : in buffered_channel() function in boost::fibers::buffered_channel
74 ~buffered_channel() { in ~buffered_channel()
79 buffered_channel( buffered_channel const&) = delete;
80 buffered_channel & operator=( buffered_channel const&) = delete;
547 buffered_channel * chan_{ nullptr };
570 explicit iterator( buffered_channel< T > * chan) noexcept : in iterator()
615 typename buffered_channel< T >::iterator
616 begin( buffered_channel< T > & chan) { in begin()
617 return typename buffered_channel< T >::iterator( & chan); in begin()
[all …]
/third_party/boost/libs/fiber/performance/thread/
Dbuffered_channel.hpp36 class buffered_channel { class
131 explicit buffered_channel( std::size_t capacity) : in buffered_channel() function in buffered_channel
142 ~buffered_channel() { in ~buffered_channel()
157 buffered_channel( buffered_channel const&) = delete;
158 buffered_channel & operator=( buffered_channel const&) = delete;
Dskynet_std.cpp15 using channel_type = buffered_channel< std::uint64_t >;
Dskynet_async.cpp28 using channel_type = buffered_channel< std::uint64_t >;
Dskynet_pthread.cpp20 using channel_type = buffered_channel< std::uint64_t >;
/third_party/boost/libs/fiber/examples/
Dwait_stuff.cpp193 void wait_first_value_impl( std::shared_ptr< boost::fibers::buffered_channel< T > > chan, in wait_first_value_impl()
205 void wait_first_value_impl( std::shared_ptr< boost::fibers::buffered_channel< T > > chan, in wait_first_value_impl()
226 typedef boost::fibers::buffered_channel< return_t > channel_t; in wait_first_value()
311 typedef boost::fibers::buffered_channel< future_t > channel_t; in wait_first_outcome()
404 typedef boost::fibers::buffered_channel< future_t > channel_t; in wait_first_success()
479 typedef boost::fibers::buffered_channel< return_t > channel_t; in wait_first_value_het()
568 nchannel( std::shared_ptr< boost::fibers::buffered_channel< T > > chan, in nchannel()
590 std::shared_ptr< boost::fibers::buffered_channel< T > > chan_;
624 std::shared_ptr< boost::fibers::buffered_channel< typename std::result_of< Fn() >::type > >
628 typedef boost::fibers::buffered_channel< return_t > channel_t; in wait_all_values_source()
[all …]
Dping_pong.cpp15 using channel_t = boost::fibers::buffered_channel< std::string >; in main()
/third_party/boost/libs/fiber/performance/fiber/
Dskynet_detach.cpp25 using channel_type = boost::fibers::buffered_channel< std::uint64_t >;
Dskynet_join.cpp25 using channel_type = boost::fibers::buffered_channel< std::uint64_t >;
Dskynet_stealing_join.cpp34 using channel_type = boost::fibers::buffered_channel< std::uint64_t >;
Dskynet_stealing_async.cpp34 using channel_type = boost::fibers::buffered_channel< std::uint64_t >;
Dskynet_stealing_detach.cpp34 using channel_type = boost::fibers::buffered_channel< std::uint64_t >;
Dskynet_shared_detach.cpp31 using channel_type = boost::fibers::buffered_channel< std::uint64_t >;
Dskynet_shared_join.cpp31 using channel_type = boost::fibers::buffered_channel< std::uint64_t >;
/third_party/boost/libs/fiber/doc/html/
Dfiber_HTML.manifest17 fiber/synchronization/channels/buffered_channel.html
/third_party/boost/libs/fiber/performance/fiber/numa/
Dskynet_stealing_detach.cpp35 using channel_type = boost::fibers::buffered_channel< std::uint64_t >;