Телеграмм чат группы ProCxx страница 15695

23:43пожаловаться #7

m

потомучто всем как-то кажется

Просто чтобы корутина была не ленивой у нее должен быть немного другой механизм. Растовские корутины можно исполнять при помощи условного while (coro.poll());. Они фактически неявно создают цикл вокруг каждого await. Плюсовые работают на continuation'ах, поэтому их нельзя resum'ить до того, как она не готова к продолжению работы.

Поэтому чтобы корутина стала жадно исполнятся, согласно моим представлениям, уже нужен полноценный экзекютер и awaitable должен иметь возможность зашедулить остановленную корутину на исполнение.

23:44пожаловаться #8

AF

>до того, как она не готова к продолжению работы
в send достатончо доьбавить next, осталось научить ждать awaitable

23:47пожаловаться #9

m

Собственно для меня проблема здесь в том, что для меня генератор - это простая конструкция которая не требует экзекютера. Поэтому мне сложно представить генератор который может жадно консьюмить данные.

23:47пожаловаться #10

AF

а awaitable и нужен чтобы ждать корутины цепочечно

23:47пожаловаться #11

AF

magras

Собственно для меня проблема здесь в том, что для меня генератор - это простая конструкция которая не требует экзекютера. Поэтому мне сложно представить генератор который может жадно консьюмить данные.

генератор который awaitит генератор

23:48пожаловаться #12

AF

await должен быть похож на
while(child.next())
yield child.value()

23:48пожаловаться #13

m

>до того, как она не готова к продолжению работы
в send достатончо доьбавить next, осталось научить ждать awaitable

Но это же практически ни чем не отличается от того, примера кода который я написал. Объединить push и next в функции и все. Для меня это чисто косметическое изменение.

23:49пожаловаться #14

AF

magras

Но это же практически ни чем не отличается от того, примера кода который я написал. Объединить push и next в функции и все. Для меня это чисто косметическое изменение.

толкьо там await ничего не ждёт(

23:50пожаловаться #15

m

толкьо там await ничего не ждёт(

А что он должен ждать? Если в публичном интерфейсе есть только метод, который одновременно пушит новое значение и пулит результат, код не может встать на await. Исходный код написан на том же предположении.

23:52пожаловаться #16

m

Если использовать низкоуровневый интерфейс с раздельным пушем и пулом, да, нужно будет еще как-то обрабатывать ситуацию когда пулят раньше пуша. Но sleep здесь вряд ли является возможным решением. Я вижу два пути: terminate и возвращать что-нибудь вроде variant<EOF, Pending, Value<T>>.

23:58пожаловаться #17

2020 September 28

m

magras

Если использовать низкоуровневый интерфейс с раздельным пушем и пулом, да, нужно будет еще как-то обрабатывать ситуацию когда пулят раньше пуша. Но sleep здесь вряд ли является возможным решением. Я вижу два пути: terminate и возвращать что-нибудь вроде variant<EOF, Pending, Value<T>>.

Но во варианте с Pending, кажется, придется заворачивать каждый await в цикл. То есть оно выглядело бы как-то так:

T t;
while (true) {
  t = co_await src;
  if (t == Pending)
    co_yield Pending;
  else
    break;
}

Другими словами видимо так делать не надо. =(

00:12пожаловаться #18

AF

https://gcc.godbolt.org/z/qTrKbM

gcc.godbolt.org

Compiler Explorer - C++ (x86-64 gcc 10.2)

struct generator_input {};

template <typename OutputType, typename InputType>
struct generator {
struct promise_type;
using coro_handle = std::coroutine_handle<promise_type>;

struct passthru_value
{
InputType &ret_;

bool await_ready() {return false;}
void await_suspend(coro_handle) {}
InputType &await_resume() { return ret_; }
};

struct promise_type {
OutputType current_value;
InputType input_value;

auto get_return_object() { return generator{coro_handle::from_promise(*this)}; }
auto initial_suspend() { return std::suspend_always{}; }
auto final_suspend() { return std::suspend_always{}; }
void unhandled_exception() { std::terminate(); }
auto yield_value(OutputType value) {
current_value = value;
return passthru_value{input_value};
}

void return_void() {}
};

bool next() { return coro ? (coro.resume(), !coro.done()) : false; }
OutputType value()…

00:15пожаловаться #19

P

PRoSToC0der in pro.cxx

https://gcc.godbolt.org/z/qTrKbM

gcc.godbolt.org

Compiler Explorer - C++ (x86-64 gcc 10.2)

struct generator_input {};

template <typename OutputType, typename InputType>
struct generator {
struct promise_type;
using coro_handle = std::coroutine_handle<promise_type>;

struct passthru_value
{
InputType &ret_;

bool await_ready() {return false;}
void await_suspend(coro_handle) {}
InputType &await_resume() { return ret_; }
};

struct promise_type {
OutputType current_value;
InputType input_value;

auto get_return_object() { return generator{coro_handle::from_promise(*this)}; }
auto initial_suspend() { return std::suspend_always{}; }
auto final_suspend() { return std::suspend_always{}; }
void unhandled_exception() { std::terminate(); }
auto yield_value(OutputType value) {
current_value = value;
return passthru_value{input_value};
}

void return_void() {}
};

bool next() { return coro ? (coro.resume(), !coro.done()) : false; }
OutputType value()…

а зачем такое может пригодиться?