1 // <generator> -*- C++ -*-
3 // Copyright (C) 2023-2024 Free Software Foundation, Inc.
5 // This file is part of the GNU ISO C++ Library. This library is free
6 // software; you can redistribute it and/or modify it under the
7 // terms of the GNU General Public License as published by the
8 // Free Software Foundation; either version 3, or (at your option)
11 // This library is distributed in the hope that it will be useful,
12 // but WITHOUT ANY WARRANTY; without even the implied warranty of
13 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 // GNU General Public License for more details.
16 // Under Section 7 of GPL version 3, you are granted additional
17 // permissions described in the GCC Runtime Library Exception, version
18 // 3.1, as published by the Free Software Foundation.
20 // You should have received a copy of the GNU General Public License and
21 // a copy of the GCC Runtime Library Exception along with this program;
22 // see the files COPYING3 and COPYING.RUNTIME respectively. If not, see
23 // <http://www.gnu.org/licenses/>.
25 /** @file include/generator
26 * This is a Standard C++ Library header.
29 #ifndef _GLIBCXX_GENERATOR
30 #define _GLIBCXX_GENERATOR
33 #pragma GCC system_header
35 #include <bits/c++config.h>
37 #define __glibcxx_want_generator
38 #include <bits/version.h>
40 #ifdef __cpp_lib_generator // C++ >= 23 && __glibcxx_coroutine
42 #include <bits/move.h>
43 #include <bits/ranges_util.h>
44 #include <bits/elements_of.h>
45 #include <bits/uses_allocator.h>
46 #include <bits/exception_ptr.h>
52 #include <type_traits>
57 # include <bits/memory_resource.h>
60 namespace std _GLIBCXX_VISIBILITY(default)
62 _GLIBCXX_BEGIN_NAMESPACE_VERSION
65 * @defgroup generator_coros Range generator coroutines
71 /** @brief A range specified using a yielding coroutine.
73 * `std::generator` is a utility class for defining ranges using coroutines
74 * that yield elements as a range. Generator coroutines are synchronous.
76 * @headerfile generator
79 template<typename _Ref, typename _V = void, typename _Alloc = void>
82 /// @cond undocumented
85 /// _Reference type for a generator whose reference (first argument) and
86 /// value (second argument) types are _Ref and _V.
87 template<typename _Ref, typename _Val>
88 using _Reference_t = __conditional_t<is_void_v<_Val>,
91 /// Type yielded by a generator whose _Reference type is _Reference.
92 template<typename _Reference>
93 using _Yield_t = __conditional_t<is_reference_v<_Reference>,
97 /// _Yield_t * _Reference_t
98 template<typename _Ref, typename _Val>
99 using _Yield2_t = _Yield_t<_Reference_t<_Ref, _Val>>;
101 template<typename> constexpr bool __is_generator = false;
102 template<typename _Val, typename _Ref, typename _Alloc>
103 constexpr bool __is_generator<std::generator<_Val, _Ref, _Alloc>> = true;
105 /// Allocator and value type erased generator promise type.
106 /// \tparam _Yielded The corresponding generators yielded type.
107 template<typename _Yielded>
108 class _Promise_erased
110 static_assert(is_reference_v<_Yielded>);
111 using _Yielded_deref = remove_reference_t<_Yielded>;
112 using _Yielded_decvref = remove_cvref_t<_Yielded>;
113 using _ValuePtr = add_pointer_t<_Yielded>;
114 using _Coro_handle = std::coroutine_handle<_Promise_erased>;
116 template<typename, typename, typename>
117 friend class std::generator;
119 template<typename _Gen>
120 struct _Recursive_awaiter;
122 friend struct _Recursive_awaiter;
123 struct _Copy_awaiter;
124 struct _Subyield_state;
125 struct _Final_awaiter;
128 initial_suspend() const noexcept
132 yield_value(_Yielded __val) noexcept
134 _M_bottom_value() = ::std::addressof(__val);
139 yield_value(const _Yielded_deref& __val)
140 noexcept (is_nothrow_constructible_v<_Yielded_decvref,
141 const _Yielded_deref&>)
142 requires (is_rvalue_reference_v<_Yielded>
143 && constructible_from<_Yielded_decvref,
144 const _Yielded_deref&>)
145 { return _Copy_awaiter(__val, _M_bottom_value()); }
147 template<typename _R2, typename _V2, typename _A2, typename _U2>
148 requires std::same_as<_Yield2_t<_R2, _V2>, _Yielded>
150 yield_value(ranges::elements_of<generator<_R2, _V2, _A2>&&, _U2> __r)
152 { return _Recursive_awaiter { std::move(__r.range) }; }
154 template<ranges::input_range _R, typename _Alloc>
155 requires convertible_to<ranges::range_reference_t<_R>, _Yielded>
157 yield_value(ranges::elements_of<_R, _Alloc> __r)
160 auto __n = [] (allocator_arg_t, _Alloc,
161 ranges::iterator_t<_R> __i,
162 ranges::sentinel_t<_R> __s)
163 -> generator<_Yielded, ranges::range_value_t<_R>, _Alloc> {
164 for (; __i != __s; ++__i)
165 co_yield static_cast<_Yielded>(*__i);
167 return yield_value(ranges::elements_of(__n(allocator_arg,
169 ranges::begin(__r.range),
170 ranges::end(__r.range))));
175 final_suspend() noexcept
179 unhandled_exception()
181 // To get to this point, this coroutine must have been active. In that
182 // case, it must be the top of the stack. The current coroutine is
183 // the sole entry of the stack iff it is both the top and the bottom. As
184 // it is the top implicitly in this context it will be the sole entry iff
186 if (_M_nest._M_is_bottom())
189 this->_M_except = std::current_exception();
192 void await_transform() = delete;
193 void return_void() const noexcept {}
197 _M_bottom_value() noexcept
198 { return _M_nest._M_bottom_value(*this); }
202 { return _M_nest._M_value(*this); }
204 _Subyield_state _M_nest;
205 std::exception_ptr _M_except;
208 template<typename _Yielded>
209 struct _Promise_erased<_Yielded>::_Subyield_state
213 _Coro_handle _M_bottom;
214 _Coro_handle _M_parent;
220 _ValuePtr _M_value = nullptr;
229 _M_is_bottom() const noexcept
230 { return !std::holds_alternative<_Frame>(this->_M_stack); }
235 if (auto __f = std::get_if<_Frame>(&this->_M_stack))
236 return __f->_M_bottom.promise()._M_nest._M_top();
238 auto __bf = std::get_if<_Bottom_frame>(&this->_M_stack);
239 __glibcxx_assert(__bf);
244 _M_push(_Coro_handle __current, _Coro_handle __subyield) noexcept
246 __glibcxx_assert(&__current.promise()._M_nest == this);
247 __glibcxx_assert(this->_M_top() == __current);
249 __subyield.promise()._M_nest._M_jump_in(__current, __subyield);
252 std::coroutine_handle<>
255 if (auto __f = std::get_if<_Frame>(&this->_M_stack))
257 // We aren't a bottom coroutine. Restore the parent to the top
259 auto __p = this->_M_top() = __f->_M_parent;
263 // Otherwise, there's nothing to resume.
264 return std::noop_coroutine();
268 _M_jump_in(_Coro_handle __rest, _Coro_handle __new) noexcept
270 __glibcxx_assert(&__new.promise()._M_nest == this);
271 __glibcxx_assert(this->_M_is_bottom());
272 // We're bottom. We're also top of top is unset (note that this is
273 // not true if something was added to the coro stack and then popped,
274 // but in that case we can't possibly be yielded from, as it would
275 // require rerunning begin()).
276 __glibcxx_assert(!this->_M_top());
278 auto& __rn = __rest.promise()._M_nest;
279 __rn._M_top() = __new;
281 // Presume we're the second frame...
282 auto __bott = __rest;
283 if (auto __f = std::get_if<_Frame>(&__rn._M_stack))
284 // But, if we aren't, get the actual bottom. We're only the second
285 // frame if our parent is the bottom frame, i.e. it doesn't have a
287 __bott = __f->_M_bottom;
289 this->_M_stack = _Frame {
296 _M_bottom_value(_Promise_erased& __current) noexcept
298 __glibcxx_assert(&__current._M_nest == this);
299 if (auto __bf = std::get_if<_Bottom_frame>(&this->_M_stack))
300 return __bf->_M_value;
301 auto __f = std::get_if<_Frame>(&this->_M_stack);
302 __glibcxx_assert(__f);
303 auto& __p = __f->_M_bottom.promise();
304 return __p._M_nest._M_value(__p);
308 _M_value(_Promise_erased& __current) noexcept
310 __glibcxx_assert(&__current._M_nest == this);
311 auto __bf = std::get_if<_Bottom_frame>(&this->_M_stack);
312 __glibcxx_assert(__bf);
313 return __bf->_M_value;
317 template<typename _Yielded>
318 struct _Promise_erased<_Yielded>::_Final_awaiter
320 bool await_ready() noexcept
323 template<typename _Promise>
324 auto await_suspend(std::coroutine_handle<_Promise> __c) noexcept
326 static_assert(is_pointer_interconvertible_base_of_v<
327 _Promise_erased, _Promise>);
329 auto& __n = __c.promise()._M_nest;
333 void await_resume() noexcept {}
336 template<typename _Yielded>
337 struct _Promise_erased<_Yielded>::_Copy_awaiter
339 _Yielded_decvref _M_value;
340 _ValuePtr& _M_bottom_value;
342 constexpr bool await_ready() noexcept
345 template<typename _Promise>
346 void await_suspend(std::coroutine_handle<_Promise>) noexcept
348 static_assert(is_pointer_interconvertible_base_of_v<
349 _Promise_erased, _Promise>);
350 _M_bottom_value = ::std::addressof(_M_value);
354 await_resume() const noexcept
358 template<typename _Yielded>
359 template<typename _Gen>
360 struct _Promise_erased<_Yielded>::_Recursive_awaiter
363 static_assert(__is_generator<_Gen>);
364 static_assert(std::same_as<typename _Gen::yielded, _Yielded>);
366 _Recursive_awaiter(_Gen __gen) noexcept
367 : _M_gen(std::move(__gen))
368 { this->_M_gen._M_mark_as_started(); }
371 await_ready() const noexcept
375 template<typename _Promise>
376 std::coroutine_handle<>
377 await_suspend(std::coroutine_handle<_Promise> __p) noexcept
379 static_assert(is_pointer_interconvertible_base_of_v<
380 _Promise_erased, _Promise>);
382 auto __c = _Coro_handle::from_address(__p.address());
383 auto __t = _Coro_handle::from_address(this->_M_gen._M_coro.address());
384 __p.promise()._M_nest._M_push(__c, __t);
390 if (auto __e = _M_gen._M_coro.promise()._M_except)
391 std::rethrow_exception(__e);
397 alignas(__STDCPP_DEFAULT_NEW_ALIGNMENT__)
398 char _M_data[__STDCPP_DEFAULT_NEW_ALIGNMENT__];
401 _M_cnt(std::size_t __sz) noexcept
403 auto __blksz = sizeof(_Alloc_block);
404 return (__sz + __blksz - 1) / __blksz;
408 template<typename _A>
409 concept _Stateless_alloc = (allocator_traits<_A>::is_always_equal::value
410 && default_initializable<_A>);
412 template<typename _Alloc>
415 using _ATr = allocator_traits<_Alloc>;
416 using _Rebound = typename _ATr::template rebind_alloc<_Alloc_block>;
417 using _Rebound_ATr = typename _ATr
418 ::template rebind_traits<_Alloc_block>;
419 static_assert(is_pointer_v<typename _Rebound_ATr::pointer>,
420 "Must use allocators for true pointers with generators");
423 _M_alloc_address(std::uintptr_t __fn, std::uintptr_t __fsz) noexcept
425 auto __an = __fn + __fsz;
426 auto __ba = alignof(_Rebound);
427 return reinterpret_cast<_Rebound*>(((__an + __ba - 1) / __ba) * __ba);
431 _M_alloc_size(std::size_t __csz) noexcept
433 auto __ba = alignof(_Rebound);
434 // Our desired layout is placing the coroutine frame, then pad out to
435 // align, then place the allocator. The total size of that is the
436 // size of the coroutine frame, plus up to __ba bytes, plus the size
438 return __csz + __ba + sizeof(_Rebound);
442 _M_allocate(_Rebound __b, std::size_t __csz)
444 if constexpr (_Stateless_alloc<_Rebound>)
445 // Only need room for the coroutine.
446 return __b.allocate(_Alloc_block::_M_cnt(__csz));
449 auto __nsz = _Alloc_block::_M_cnt(_M_alloc_size(__csz));
450 auto __f = __b.allocate(__nsz);
451 auto __fn = reinterpret_cast<std::uintptr_t>(__f);
452 auto __an = _M_alloc_address(__fn, __csz);
453 ::new (__an) _Rebound(std::move(__b));
460 operator new(std::size_t __sz)
461 requires default_initializable<_Rebound> // _Alloc is non-void
462 { return _M_allocate({}, __sz); }
464 template<typename _Na, typename... _Args>
466 operator new(std::size_t __sz,
467 allocator_arg_t, const _Na& __na,
469 requires convertible_to<const _Na&, _Alloc>
471 return _M_allocate(static_cast<_Rebound>(static_cast<_Alloc>(__na)),
475 template<typename _This, typename _Na, typename... _Args>
477 operator new(std::size_t __sz,
479 allocator_arg_t, const _Na& __na,
481 requires convertible_to<const _Na&, _Alloc>
483 return _M_allocate(static_cast<_Rebound>(static_cast<_Alloc>(__na)),
488 operator delete(void* __ptr, std::size_t __csz) noexcept
490 if constexpr (_Stateless_alloc<_Rebound>)
493 return __b.deallocate(reinterpret_cast<_Alloc_block*>(__ptr),
494 _Alloc_block::_M_cnt(__csz));
498 auto __nsz = _Alloc_block::_M_cnt(_M_alloc_size(__csz));
499 auto __fn = reinterpret_cast<std::uintptr_t>(__ptr);
500 auto __an = _M_alloc_address(__fn, __csz);
501 _Rebound __b(std::move(*__an));
503 __b.deallocate(reinterpret_cast<_Alloc_block*>(__ptr), __nsz);
509 class _Promise_alloc<void>
511 using _Dealloc_fn = void (*)(void*, std::size_t);
514 _M_dealloc_address(std::uintptr_t __fn, std::uintptr_t __fsz) noexcept
516 auto __an = __fn + __fsz;
517 auto __ba = alignof(_Dealloc_fn);
518 auto __aligned = ((__an + __ba - 1) / __ba) * __ba;
519 return reinterpret_cast<_Dealloc_fn*>(__aligned);
522 template<typename _Rebound>
524 _M_alloc_address(std::uintptr_t __fn, std::uintptr_t __fsz) noexcept
525 requires (!_Stateless_alloc<_Rebound>)
527 auto __ba = alignof(_Rebound);
528 auto __da = _M_dealloc_address(__fn, __fsz);
529 auto __aan = reinterpret_cast<std::uintptr_t>(__da);
530 __aan += sizeof(_Dealloc_fn);
531 auto __aligned = ((__aan + __ba - 1) / __ba) * __ba;
532 return reinterpret_cast<_Rebound*>(__aligned);
535 template<typename _Rebound>
537 _M_alloc_size(std::size_t __csz) noexcept
539 // This time, we want the coroutine frame, then the deallocator
540 // pointer, then the allocator itself, if any.
541 std::size_t __aa = 0;
542 std::size_t __as = 0;
543 if constexpr (!std::same_as<_Rebound, void>)
545 __aa = alignof(_Rebound);
546 __as = sizeof(_Rebound);
548 auto __ba = __aa + alignof(_Dealloc_fn);
549 return __csz + __ba + __as + sizeof(_Dealloc_fn);
552 template<typename _Rebound>
554 _M_deallocator(void* __ptr, std::size_t __csz) noexcept
556 auto __asz = _M_alloc_size<_Rebound>(__csz);
557 auto __nblk = _Alloc_block::_M_cnt(__asz);
559 if constexpr (_Stateless_alloc<_Rebound>)
562 __b.deallocate(reinterpret_cast<_Alloc_block*>(__ptr), __nblk);
566 auto __fn = reinterpret_cast<std::uintptr_t>(__ptr);
567 auto __an = _M_alloc_address<_Rebound>(__fn, __csz);
568 _Rebound __b(std::move(*__an));
570 __b.deallocate(reinterpret_cast<_Alloc_block*>(__ptr), __nblk);
574 template<typename _Na>
576 _M_allocate(const _Na& __na, std::size_t __csz)
578 using _Rebound = typename std::allocator_traits<_Na>
579 ::template rebind_alloc<_Alloc_block>;
580 using _Rebound_ATr = typename std::allocator_traits<_Na>
581 ::template rebind_traits<_Alloc_block>;
583 static_assert(is_pointer_v<typename _Rebound_ATr::pointer>,
584 "Must use allocators for true pointers with generators");
586 _Dealloc_fn __d = &_M_deallocator<_Rebound>;
587 auto __b = static_cast<_Rebound>(__na);
588 auto __asz = _M_alloc_size<_Rebound>(__csz);
589 auto __nblk = _Alloc_block::_M_cnt(__asz);
590 void* __p = __b.allocate(__nblk);
591 auto __pn = reinterpret_cast<std::uintptr_t>(__p);
592 *_M_dealloc_address(__pn, __csz) = __d;
593 if constexpr (!_Stateless_alloc<_Rebound>)
595 auto __an = _M_alloc_address<_Rebound>(__pn, __csz);
596 ::new (__an) _Rebound(std::move(__b));
602 operator new(std::size_t __sz)
604 auto __nsz = _M_alloc_size<void>(__sz);
605 _Dealloc_fn __d = [] (void* __ptr, std::size_t __sz)
607 ::operator delete(__ptr, _M_alloc_size<void>(__sz));
609 auto __p = ::operator new(__nsz);
610 auto __pn = reinterpret_cast<uintptr_t>(__p);
611 *_M_dealloc_address(__pn, __sz) = __d;
615 template<typename _Na, typename... _Args>
617 operator new(std::size_t __sz,
618 allocator_arg_t, const _Na& __na,
620 { return _M_allocate(__na, __sz); }
622 template<typename _This, typename _Na, typename... _Args>
624 operator new(std::size_t __sz,
626 allocator_arg_t, const _Na& __na,
628 { return _M_allocate(__na, __sz); }
631 operator delete(void* __ptr, std::size_t __sz) noexcept
634 auto __pn = reinterpret_cast<uintptr_t>(__ptr);
635 __d = *_M_dealloc_address(__pn, __sz);
640 template<typename _Tp>
641 concept _Cv_unqualified_object = is_object_v<_Tp>
642 && same_as<_Tp, remove_cv_t<_Tp>>;
646 template<typename _Ref, typename _V, typename _Alloc>
648 : public ranges::view_interface<generator<_Ref, _V, _Alloc>>
650 using _Value = __conditional_t<is_void_v<_V>, remove_cvref_t<_Ref>, _V>;
651 static_assert(__gen::_Cv_unqualified_object<_Value>,
652 "Generator value must be a cv-unqualified object type");
653 using _Reference = __gen::_Reference_t<_Ref, _V>;
654 static_assert(is_reference_v<_Reference>
655 || (__gen::_Cv_unqualified_object<_Reference>
656 && copy_constructible<_Reference>),
657 "Generator reference type must be either a cv-unqualified "
658 "object type that is trivially constructible or a "
661 using _RRef = __conditional_t<
662 is_reference_v<_Reference>,
663 remove_reference_t<_Reference>&&,
666 /* Required to model indirectly_readable, and input_iterator. */
667 static_assert(common_reference_with<_Reference&&, _Value&&>);
668 static_assert(common_reference_with<_Reference&&, _RRef&&>);
669 static_assert(common_reference_with<_RRef&&, const _Value&>);
671 using _Yielded = __gen::_Yield_t<_Reference>;
672 using _Erased_promise = __gen::_Promise_erased<_Yielded>;
676 friend _Erased_promise;
677 friend struct _Erased_promise::_Subyield_state;
679 using yielded = _Yielded;
681 struct promise_type : _Erased_promise, __gen::_Promise_alloc<_Alloc>
683 generator get_return_object() noexcept
684 { return { coroutine_handle<promise_type>::from_promise(*this) }; }
687 static_assert(is_pointer_interconvertible_base_of_v<_Erased_promise,
690 generator(const generator&) = delete;
692 generator(generator&& __other) noexcept
693 : _M_coro(std::__exchange(__other._M_coro, nullptr)),
694 _M_began(std::__exchange(__other._M_began, false))
699 if (auto& __c = this->_M_coro)
704 operator=(generator __other) noexcept
706 swap(__other._M_coro, this->_M_coro);
707 swap(__other._M_began, this->_M_began);
713 this->_M_mark_as_started();
714 auto __h = _Coro_handle::from_promise(_M_coro.promise());
715 __h.promise()._M_nest._M_top() = __h;
721 { return default_sentinel; }
724 using _Coro_handle = std::coroutine_handle<_Erased_promise>;
726 generator(coroutine_handle<promise_type> __coro) noexcept
727 : _M_coro { move(__coro) }
731 _M_mark_as_started() noexcept
733 __glibcxx_assert(!this->_M_began);
734 this->_M_began = true;
737 coroutine_handle<promise_type> _M_coro;
738 bool _M_began = false;
741 template<class _Ref, class _V, class _Alloc>
742 struct generator<_Ref, _V, _Alloc>::_Iterator
744 using value_type = _Value;
745 using difference_type = ptrdiff_t;
748 operator==(const _Iterator& __i, default_sentinel_t) noexcept
749 { return __i._M_coro.done(); }
751 friend class generator;
753 _Iterator(_Iterator&& __o) noexcept
754 : _M_coro(std::__exchange(__o._M_coro, {}))
758 operator=(_Iterator&& __o) noexcept
760 this->_M_coro = std::__exchange(__o._M_coro, {});
773 { this->operator++(); }
777 const noexcept(is_nothrow_move_constructible_v<_Reference>)
779 auto& __p = this->_M_coro.promise();
780 return static_cast<yielded>(*__p._M_value());
784 friend class generator;
786 _Iterator(_Coro_handle __g)
792 auto& __t = this->_M_coro.promise()._M_nest._M_top();
796 _Coro_handle _M_coro;
803 template<typename _Ref, typename _Val = void>
804 using generator = std::generator<_Ref, _Val, polymorphic_allocator<std::byte>>;
808 _GLIBCXX_END_NAMESPACE_VERSION
810 #endif // __cpp_lib_generator
812 #endif // _GLIBCXX_GENERATOR