Gecko [ www.jdcpatala.org ]

Name	Size	Permission
bits	[ DIR ]	drwxr-xr-x
algorithm	3.57 KB	-rw-r--r--
any	15.58 KB	-rw-r--r--
array	3.16 KB	-rw-r--r--
buffer	28.03 KB	-rw-r--r--
chrono	1.89 KB	-rw-r--r--
deque	2.22 KB	-rw-r--r--
executor	52.77 KB	-rw-r--r--
filesystem	1.53 KB	-rw-r--r--
forward_list	2.29 KB	-rw-r--r--
functional	12 KB	-rw-r--r--
internet	64.03 KB	-rw-r--r--
io_context	20.81 KB	-rw-r--r--
iterator	3.43 KB	-rw-r--r--
list	2.19 KB	-rw-r--r--
map	2.51 KB	-rw-r--r--
memory	5.89 KB	-rw-r--r--
memory_resource	16.03 KB	-rw-r--r--
net	1.48 KB	-rw-r--r--
netfwd	3.52 KB	-rw-r--r--
numeric	3.12 KB	-rw-r--r--
optional	28.2 KB	-rw-r--r--
propagate_const	14.95 KB	-rw-r--r--
random	2.49 KB	-rw-r--r--
ratio	2.36 KB	-rw-r--r--
regex	2.05 KB	-rw-r--r--
set	2.39 KB	-rw-r--r--
socket	74.42 KB	-rw-r--r--
source_location	2.69 KB	-rw-r--r--
string	2.83 KB	-rw-r--r--
string_view	21.5 KB	-rw-r--r--
system_error	1.97 KB	-rw-r--r--
timer	5.63 KB	-rw-r--r--
tuple	2.39 KB	-rw-r--r--
type_traits	10.69 KB	-rw-r--r--
unordered_map	2.75 KB	-rw-r--r--
unordered_set	2.64 KB	-rw-r--r--
utility	1.67 KB	-rw-r--r--
vector	2.28 KB	-rw-r--r--

Code Editor : timer

// <experimental/timer> -*- C++ -*-

// Copyright (C) 2015-2019 Free Software Foundation, Inc.
//
// This file is part of the GNU ISO C++ Library.  This library is free
// software; you can redistribute it and/or modify it under the
// terms of the GNU General Public License as published by the
// Free Software Foundation; either version 3, or (at your option)
// any later version.

// This library is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.

// Under Section 7 of GPL version 3, you are granted additional
// permissions described in the GCC Runtime Library Exception, version
// 3.1, as published by the Free Software Foundation.

// You should have received a copy of the GNU General Public License and
// a copy of the GCC Runtime Library Exception along with this program;
// see the files COPYING3 and COPYING.RUNTIME respectively.  If not, see
// <http://www.gnu.org/licenses/>.

/** @file experimental/timer
 *  This is a TS C++ Library header.
 */

#ifndef _GLIBCXX_EXPERIMENTAL_TIMER
#define _GLIBCXX_EXPERIMENTAL_TIMER 1

#pragma GCC system_header

#if __cplusplus >= 201402L

#include <chrono>
#include <system_error>
#include <thread>
#include <experimental/netfwd>
#include <experimental/io_context>
#include <experimental/bits/net.h>

namespace std _GLIBCXX_VISIBILITY(default)
{
_GLIBCXX_BEGIN_NAMESPACE_VERSION
namespace experimental
{
namespace net
{
inline namespace v1
{

/**
   * @ingroup networking
   * @{
   */

template<typename _Clock>
    struct wait_traits
    {
      static typename _Clock::duration
      to_wait_duration(const typename _Clock::duration& __d)
      { return __d; }

static typename _Clock::duration
      to_wait_duration(const typename _Clock::time_point& __t)
      {
	auto __now = _Clock::now();
	auto __diff = __t - __now;
	if (__diff > _Clock::duration::max())
	  return _Clock::duration::max();
	if (__diff < _Clock::duration::min())
	  return _Clock::duration::min();
	return __diff;
      }
    };

template<typename _Clock, typename _WaitTraits>
    class basic_waitable_timer
    {
    public:
      // types:

typedef io_context::executor_type executor_type;
      typedef _Clock clock_type;
      typedef typename clock_type::duration duration;
      typedef typename clock_type::time_point time_point;
      typedef _WaitTraits traits_type;

// construct / copy / destroy:

explicit
      basic_waitable_timer(io_context& __ctx)
      : _M_ex(__ctx.get_executor()), _M_expiry()
      { }

basic_waitable_timer(io_context& __ctx, const time_point& __t)
      : _M_ex(__ctx.get_executor()), _M_expiry(__t)
      { }

basic_waitable_timer(io_context& __ctx, const duration& __d)
      : _M_ex(__ctx.get_executor()), _M_expiry(_Clock::now() + __d)
      { }

basic_waitable_timer(const basic_waitable_timer&) = delete;

basic_waitable_timer(basic_waitable_timer&& __rhs)
      : _M_ex(std::move(__rhs._M_ex)), _M_expiry(__rhs._M_expiry)
      {
	_M_key.swap(__rhs._M_key);
	__rhs._M_expiry = time_point{};
      }

~basic_waitable_timer() { cancel(); }

basic_waitable_timer& operator=(const basic_waitable_timer&) = delete;

basic_waitable_timer&
      operator=(basic_waitable_timer&& __rhs)
      {
	if (this == std::addressof(__rhs))
	  return *this;
	cancel();
	_M_ex = std::move(__rhs._M_ex);
	_M_expiry = __rhs._M_expiry;
	__rhs._M_expiry = time_point{};
	_M_key.swap(__rhs._M_key);
	return *this;
      }

// basic_waitable_timer operations:

executor_type get_executor() noexcept { return _M_ex; }

size_t cancel() { return _M_ex.context().cancel(*this); }
      size_t cancel_one() { return _M_ex.context().cancel_one(*this); }

time_point expiry() const { return _M_expiry; }

size_t expires_at(const time_point& __t)
      {
	size_t __cancelled = cancel();
	_M_expiry = __t;
	return __cancelled;
      }

size_t expires_after(const duration& __d)
      { return expires_at(_Clock::now() + __d); }

void wait();
      void wait(error_code& __ec);

template<typename _CompletionToken>
	__deduced_t<_CompletionToken, void(error_code)>
	async_wait(_CompletionToken&& __token)
	{
	  async_completion<_CompletionToken, void(error_code)> __init(__token);
	  _M_ex.context().async_wait(*this,
				     std::move(__init.completion_handler));
	  return __init.result.get();
	}

private:
      executor_type _M_ex;
      time_point _M_expiry;

struct _Key { };  // TODO move _M_expiry into here?
      unique_ptr<_Key> _M_key{new _Key};

friend class io_context;
    };

typedef basic_waitable_timer<chrono::system_clock> system_timer;
  typedef basic_waitable_timer<chrono::steady_clock> steady_timer;
  typedef basic_waitable_timer<chrono::high_resolution_clock>
    high_resolution_timer;

template<typename _Clock, typename _WaitTraits>
    void
    basic_waitable_timer<_Clock, _WaitTraits>::wait()
    {
      _M_ex.dispatch([this] {
	  while (clock_type::now() < _M_expiry)
	    this_thread::sleep_for(traits_type::to_wait_duration(_M_expiry));
      }, allocator<void>{});
    }

template<typename _Clock, typename _WaitTraits>
    void
    basic_waitable_timer<_Clock, _WaitTraits>::wait(error_code&)
    {
      _M_ex.dispatch([this] {
	  while (clock_type::now() < _M_expiry)
	    this_thread::sleep_for(traits_type::to_wait_duration(_M_expiry));
      }, allocator<void>{});
    }

/// @}

} // namespace v1
} // namespace net
} // namespace experimental
_GLIBCXX_END_NAMESPACE_VERSION
} // namespace std

#endif // C++14

#endif // _GLIBCXX_EXPERIMENTAL_TIMER

${this.title}

Code Editor : timer