2
0
mirror of https://github.com/boostorg/asio.git synced 2026-01-28 18:52:09 +00:00
Files
asio/example/timers/tick_count_timer.cpp
Christopher Kohlhoff 2b5306585d Merge fixes from trunk.
........
  r43377 | chris_kohlhoff | 2008-02-23 09:43:54 +1100 (Sat, 23 Feb 2008) | 2 lines
  
  Use the correct vector of timer queues when dispatching timers.
........
  r43437 | chris_kohlhoff | 2008-02-29 23:57:57 +1100 (Fri, 29 Feb 2008) | 2 lines
  
  Add missing tie().
........
  r43469 | chris_kohlhoff | 2008-03-04 00:21:05 +1100 (Tue, 04 Mar 2008) | 4 lines
  
  Disable use of CancelIo by default, due to the possibility of silent
  failure on some system configurations. Swallow error returned by CancelIoEx
  if there are no operations to be cancelled.
........
  r43470 | chris_kohlhoff | 2008-03-04 00:27:06 +1100 (Tue, 04 Mar 2008) | 2 lines
  
  Add missing 'boost_' prefix to helper namespace.
........
  r43471 | chris_kohlhoff | 2008-03-04 00:36:35 +1100 (Tue, 04 Mar 2008) | 2 lines
  
  Regenerate documentation.
........
  r43472 | chris_kohlhoff | 2008-03-04 01:05:35 +1100 (Tue, 04 Mar 2008) | 1 line
  
  Update copyright notices.
........
  r43473 | chris_kohlhoff | 2008-03-04 01:13:01 +1100 (Tue, 04 Mar 2008) | 2 lines
  
  Update copyright notices.
........
  r43569 | chris_kohlhoff | 2008-03-13 00:25:49 +1100 (Thu, 13 Mar 2008) | 4 lines
  
  Revert to having the windows-bug workaround (short timeout on
  GetQueuedCompletionStatus) on all threads as there are still scenarios
  where threads can get stuck indefinitely.
........


[SVN r43571]
2008-03-12 14:12:08 +00:00

117 lines
2.8 KiB
C++

//
// tick_count_timer.cpp
// ~~~~~~~~~~~~~~~~~~~~
//
// Copyright (c) 2003-2008 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)
//
#include <boost/asio.hpp>
#include <ctime>
#include <iostream>
#if defined(WIN32)
# include <windows.h>
#else
# error This example is for Windows only!
#endif
struct tick_count_traits
{
// The time type. This type has no constructor that takes a DWORD to ensure
// that the timer can only be used with relative times.
class time_type
{
public:
time_type() : ticks_(0) {}
private:
friend struct tick_count_traits;
DWORD ticks_;
};
// The duration type.
class duration_type
{
public:
duration_type() : ticks_(0) {}
duration_type(DWORD ticks) : ticks_(ticks) {}
private:
friend struct tick_count_traits;
DWORD ticks_;
};
// Get the current time.
static time_type now()
{
time_type result;
result.ticks_ = ::GetTickCount();
return result;
}
// Add a duration to a time.
static time_type add(const time_type& t, const duration_type& d)
{
time_type result;
result.ticks_ = t.ticks_ + d.ticks_;
return result;
}
// Subtract one time from another.
static duration_type subtract(const time_type& t1, const time_type& t2)
{
return duration_type(t1.ticks_ - t2.ticks_);
}
// Test whether one time is less than another.
static bool less_than(const time_type& t1, const time_type& t2)
{
// DWORD tick count values wrap periodically, so we'll use a heuristic that
// says that if subtracting t1 from t2 yields a value smaller than 2^31,
// then t1 is probably less than t2. This means that we can't handle
// durations larger than 2^31, which shouldn't be a problem in practice.
return (t2.ticks_ - t1.ticks_) < static_cast<DWORD>(1 << 31);
}
// Convert to POSIX duration type.
static boost::posix_time::time_duration to_posix_duration(
const duration_type& d)
{
return boost::posix_time::milliseconds(d.ticks_);
}
};
typedef boost::asio::basic_deadline_timer<
DWORD, tick_count_traits> tick_count_timer;
void handle_timeout(const boost::system::error_code&)
{
std::cout << "handle_timeout\n";
}
int main()
{
try
{
boost::asio::io_service io_service;
tick_count_timer timer(io_service, 5000);
std::cout << "Starting synchronous wait\n";
timer.wait();
std::cout << "Finished synchronous wait\n";
timer.expires_from_now(5000);
std::cout << "Starting asynchronous wait\n";
timer.async_wait(handle_timeout);
io_service.run();
std::cout << "Finished asynchronous wait\n";
}
catch (std::exception& e)
{
std::cout << "Exception: " << e.what() << "\n";
}
return 0;
}