6

実行中のタイマーを呼び出すexpires_from_now()と、タイマーはキャンセルされ、新しいタイマーが呼び出されます。したがって、関連するハンドラが呼び出されます。ハンドラーで、キャンセルされたタイマーと期限切れのタイマーを簡単に区別できます。それでも、期限切れのタイマーと再トリガーされたタイマーを区別する方法があるかどうか疑問に思っています。どちらの場合も、ハンドラーは error_code で呼び出されますoperation_aborted。または多分私はいくつかの詳細を見逃しています。

以下のコードは、次の出力を生成します。

20120415 21:32:28079507 Main: Timer1 set to 15 s.    
20120415 21:32:28079798 Main: Timer1 set to 12 s.    
20120415 21:32:28079916 Handler1: Timer 1 was cancelled or retriggered.    
20120415 21:32:40079860 Handler1: expired.

これは、ハンドラーがキャンセルされたハンドラーのアクションを実装できないことを示唆しています。これは、タイマーを再トリガーすると同じハンドラーが呼び出され、同じアクションが実行されるためです。これはおそらく意図した動作ではありません。

#include <boost/asio.hpp> 
#include <boost/thread.hpp> 
#include <boost/date_time/posix_time/posix_time.hpp>
#include <boost/date_time/posix_time/posix_time_io.hpp>
#include <iostream> 

using namespace boost::posix_time;
using namespace std;

void handler1(const boost::system::error_code &ec) 
{ 
    if (ec == boost::asio::error::operation_aborted)
    {
        cout << microsec_clock::local_time() << " Handler1: Timer was cancelled or retriggered." << endl; 
    }
    else
    {
        cout << microsec_clock::local_time() << " Handler1: Timer expired." << endl; 
    }
} 

boost::asio::io_service io_service1; 

void run1() 
{ 
    io_service1.run(); 
} 

int main() 
{ 
    time_facet *facet = new time_facet("%Y%m%d %H:%M:%S%f");
    cout.imbue(locale(cout.getloc(), facet));

    boost::asio::deadline_timer timer1(io_service1, seconds(15)); 
    timer1.async_wait(handler1); 
    cout << microsec_clock::local_time() << " Main: Timer1 set to 15 s." << endl; 
    // now actually run the timer
    boost::thread thread1(run1); 
    timer1.expires_from_now(seconds(12));
    cout << microsec_clock::local_time() << " Main: Timer1 set to 12 s." << endl; 
    // here the timer is running, but we need to reset the deadline
    timer1.async_wait(handler1); 
    thread1.join();   // wait for thread1 to terminate 
}
4

2 に答える 2

4

deadline_timerusing コンポジションをラッパーするクラスを作成することをお勧めします。キャンセルするときは、キャンセルされたことを記憶するフラグを設定します。ハンドラーで、フラグをリセットします。呼び出し時expires_from_now()にフラグを設定しないでください。

#include <boost/asio.hpp> 
#include <boost/thread.hpp> 
#include <boost/date_time/posix_time/posix_time.hpp>
#include <boost/date_time/posix_time/posix_time_io.hpp>
#include <iostream> 

class Timer
{
public:
    Timer(
            const std::string& name,
            boost::asio::io_service& io_service
         ) :
        _name( name ),
        _timer( io_service ),
        _cancelled( false )
    {
        _timer.expires_from_now( boost::posix_time::seconds(0) );
        this->wait();
    }

    void wait()
    {
        _timer.async_wait(
                boost::bind(
                    &Timer::handler,
                    this,
                    boost::asio::placeholders::error
                    )
                );
    }

    void cancel() { 
        _cancelled = true;
        _timer.cancel(); 
    }

    void restart() {
        _timer.expires_from_now( boost::posix_time::seconds(5) );
    }

private:
    void handler(
            const boost::system::error_code& error
            )
    {
        if ( !error ) {
            std::cout << _name << " " << __FUNCTION__ << std::endl;
            _timer.expires_from_now( boost::posix_time::seconds(5) );
            this->wait();
        } else if ( error == boost::asio::error::operation_aborted && _cancelled ) {
            _cancelled = false;
            std::cout << _name << " " << __FUNCTION__ << " cancelled" << std::endl;
        } else if ( error == boost::asio::error::operation_aborted ) {
            std::cout  << _name << " " << __FUNCTION__ << " retriggered" << std::endl;
            this->wait();
        } else {
            std::cout << "other error: " << boost::system::system_error(error).what() << std::endl;
        }
    }

private:
    const std::string _name;
    boost::asio::deadline_timer _timer;
    bool _cancelled;
};

int
main()
{
    boost::asio::io_service ios;
    Timer timer1( "timer1", ios );
    Timer timer2( "timer2", ios );

    boost::thread thread(
            boost::bind(
                &boost::asio::io_service::run,
                boost::ref(ios)
                )
            );

    sleep( 3 );
    std::cout << "cancelling" << std::endl;
    timer1.cancel();
    timer2.restart();

    thread.join();
}

サンプルセッション

macmini:stackoverflow samm$ ./a.out
timer1 handler
timer2 handler
cancelling
timer1 handler cancelled
timer2 handler retriggered
timer2 handler
^C
macmini:stackoverflow samm$
于 2012-04-16T02:27:51.330 に答える
0

私は方法を知りませんし、おそらくそれを行う良い方法もありません (ドキュメントには、これら 2 つの状況を区別できるとは何も書かれていません)。

これは意図的に行われたと思います。新しい有効期限に設定deadline_timerすると、以前のハンドラーがキャンセルされます。理由は次のとおりです。

  • 何かがタイマーですでに待機しているかどうかを判断するのが難しい場合があるため、有効期限を設定したときに何が起こるかを正確に判断するのは困難です。
  • これは、スケジュールされたイベントが 2 回実行されるのを防ぐ簡単な方法です。特別な方法で別のエラー コードを処理する必要があると、エラーが発生しやすくなります。
于 2012-04-15T19:58:25.640 に答える