/third_party/boost/libs/fiber/doc/ |
D | buffered_channel.qbk | 8 [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 …]
|
D | when_any.qbk | 140 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.
|
D | worker.qbk | 61 boost::fibers::buffered_channel<task> ch{1024};
|
D | fibers.qbk | 279 [include buffered_channel.qbk]
|
/third_party/boost/libs/fiber/test/ |
D | test_buffered_channel_dispatch.cpp | 51 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 …]
|
D | test_buffered_channel_post.cpp | 51 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/ |
D | buffered_channel.hpp | 35 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/ |
D | buffered_channel.hpp | 36 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;
|
D | skynet_std.cpp | 15 using channel_type = buffered_channel< std::uint64_t >;
|
D | skynet_async.cpp | 28 using channel_type = buffered_channel< std::uint64_t >;
|
D | skynet_pthread.cpp | 20 using channel_type = buffered_channel< std::uint64_t >;
|
/third_party/boost/libs/fiber/examples/ |
D | wait_stuff.cpp | 193 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 …]
|
D | ping_pong.cpp | 15 using channel_t = boost::fibers::buffered_channel< std::string >; in main()
|
/third_party/boost/libs/fiber/performance/fiber/ |
D | skynet_detach.cpp | 25 using channel_type = boost::fibers::buffered_channel< std::uint64_t >;
|
D | skynet_join.cpp | 25 using channel_type = boost::fibers::buffered_channel< std::uint64_t >;
|
D | skynet_stealing_join.cpp | 34 using channel_type = boost::fibers::buffered_channel< std::uint64_t >;
|
D | skynet_stealing_async.cpp | 34 using channel_type = boost::fibers::buffered_channel< std::uint64_t >;
|
D | skynet_stealing_detach.cpp | 34 using channel_type = boost::fibers::buffered_channel< std::uint64_t >;
|
D | skynet_shared_detach.cpp | 31 using channel_type = boost::fibers::buffered_channel< std::uint64_t >;
|
D | skynet_shared_join.cpp | 31 using channel_type = boost::fibers::buffered_channel< std::uint64_t >;
|
/third_party/boost/libs/fiber/doc/html/ |
D | fiber_HTML.manifest | 17 fiber/synchronization/channels/buffered_channel.html
|
/third_party/boost/libs/fiber/performance/fiber/numa/ |
D | skynet_stealing_detach.cpp | 35 using channel_type = boost::fibers::buffered_channel< std::uint64_t >;
|