Здраствуйте,

В своем сетевом приложении хочу организовать управление количеством отправляемых по TCP-соединению сообщений. Я пробовал использовать разделяемую переменную с таймером, который ее обнулял, но получилась ерунда.  У кого-нибудь есть идея как это сделать правильно?

не совсем прнятно что такое 

и для чего это...
но идея с таймером вполне нормальная.

P.S.
что эта тема делаей в этом разделе?

Смысл следющий - клиент по TCP соединяется с сервером и отсылает на него бинарные сообщения. Я пытался организовать отправку с контролем скорости следующим образом - один объект содержит счетчик и таймер, который раз в секунду обнуляет его. Поток, который пишет в соединение каждый раз проверяет число счетчика, если оно небольше чем максимально допустимое, то сообщение отправляеться и счетчик увеличивается на 1. Соответственно таймер тикает раз в секунду и сбрасывает счетчик в ноль. Может существует алгоритм, который организует это проще?

<code>
class CGauge: public ACE_Event_Handler
{
public:
    CGauge();
    virtual ~CGauge();
    void Nullize();
    int handle_timeout(const ACE_Time_Value& tv,const void *arg = 0);
    void Inc();
    int GetCnt();
private:
    int _cnt ;
    ACE_Thread_Mutex _nullize_mutex;

};

CGauge::CGauge()
{
    _cnt = 0 ;
    ACE_Time_Value tv (1, 0);
    ACE_Reactor::instance()->schedule_timer(this,0,tv,tv);
}

CGauge::~CGauge()
{
    ACE_Reactor::instance()->remove_handler(this,ACE_Event_Handler::DONT_CALL);
}

void CGauge::Nullize()
{
    _nullize_mutex.acquire();
    _cnt = 0;
    _nullize_mutex.release();
}

void CGauge::Inc()
{
    _nullize_mutex.acquire();
    ++_cnt;
    _nullize_mutex.release();
}


int CGauge::handle_timeout(const ACE_Time_Value& tv, const void *arg)
{
    //ACE_DEBUG((LM_DEBUG,"%T Gauge nullizing\n"));
    this->Nullize();
    return 0;
}

int CGauge::GetCnt()
{
    int r;
    _nullize_mutex.acquire();
    r = _cnt ;
    _nullize_mutex.release();
    return r ;
}

</code>