mirror of
https://github.com/boostorg/asio.git
synced 2026-01-28 06:42:08 +00:00
........ r58900 | chris_kohlhoff | 2010-01-11 23:22:33 +1100 (Mon, 11 Jan 2010) | 2 lines Add HTTP Server 4 example. ........ r59103 | chris_kohlhoff | 2010-01-18 08:42:36 +1100 (Mon, 18 Jan 2010) | 2 lines Add coroutine::is_complete() and support for "yield break;". ........ r59104 | chris_kohlhoff | 2010-01-18 08:48:17 +1100 (Mon, 18 Jan 2010) | 2 lines Document ordering of handlers in strands. Fix error in streambuf snippet. ........ r59106 | chris_kohlhoff | 2010-01-18 09:21:21 +1100 (Mon, 18 Jan 2010) | 2 lines Update revision history. ........ [SVN r59110]
80 lines
1.9 KiB
C++
80 lines
1.9 KiB
C++
//
|
|
// coroutine.hpp
|
|
// ~~~~~~~~~~~~~
|
|
//
|
|
// Copyright (c) 2003-2010 Christopher M. Kohlhoff (chris at kohlhoff dot com)
|
|
//
|
|
// Distributed under the Boost Software License, Version 1.0. (See accompanying
|
|
// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
|
|
//
|
|
|
|
#ifndef COROUTINE_HPP
|
|
#define COROUTINE_HPP
|
|
|
|
class coroutine
|
|
{
|
|
public:
|
|
coroutine() : value_(0) {}
|
|
bool is_child() const { return value_ < 0; }
|
|
bool is_parent() const { return !is_child(); }
|
|
bool is_complete() const { return value_ == -1; }
|
|
private:
|
|
friend class coroutine_ref;
|
|
int value_;
|
|
};
|
|
|
|
class coroutine_ref
|
|
{
|
|
public:
|
|
coroutine_ref(coroutine& c) : value_(c.value_), modified_(false) {}
|
|
coroutine_ref(coroutine* c) : value_(c->value_), modified_(false) {}
|
|
~coroutine_ref() { if (!modified_) value_ = -1; }
|
|
operator int() const { return value_; }
|
|
int& operator=(int v) { modified_ = true; return value_ = v; }
|
|
private:
|
|
void operator=(const coroutine_ref&);
|
|
int& value_;
|
|
bool modified_;
|
|
};
|
|
|
|
#define CORO_REENTER(c) \
|
|
switch (coroutine_ref _coro_value = c) \
|
|
case -1: if (_coro_value) \
|
|
{ \
|
|
goto terminate_coroutine; \
|
|
terminate_coroutine: \
|
|
_coro_value = -1; \
|
|
goto bail_out_of_coroutine; \
|
|
bail_out_of_coroutine: \
|
|
break; \
|
|
} \
|
|
else case 0:
|
|
|
|
#define CORO_YIELD \
|
|
for (_coro_value = __LINE__;;) \
|
|
if (_coro_value == 0) \
|
|
{ \
|
|
case __LINE__: ; \
|
|
break; \
|
|
} \
|
|
else \
|
|
switch (_coro_value ? 0 : 1) \
|
|
for (;;) \
|
|
case -1: if (_coro_value) \
|
|
goto terminate_coroutine; \
|
|
else for (;;) \
|
|
case 1: if (_coro_value) \
|
|
goto bail_out_of_coroutine; \
|
|
else case 0:
|
|
|
|
#define CORO_FORK \
|
|
for (_coro_value = -__LINE__;; _coro_value = __LINE__) \
|
|
if (_coro_value == __LINE__) \
|
|
{ \
|
|
case -__LINE__: ; \
|
|
break; \
|
|
} \
|
|
else
|
|
|
|
#endif // COROUTINE_HPP
|