void
MultiThreadingPartition::Run (void)
{
  pthread_mutex_lock (&m_partitionLock);
  m_stop = false;
  if (m_updateMaxTime)
    {
      Time maxTime = ComputeMaxTime ();
      m_maxTs = maxTime.GetHighPrecision ().GetInteger ();
      m_updateMaxTime = false;
    }
  while (!m_stop)
    {
      pthread_mutex_lock (&m_messagesLock);
      while (!m_messages.empty ())
        {
          Scheduler::Event ev = m_messages.front ();
          m_messages.pop ();
          NS_ASSERT (ev.key.m_ts >= m_currentTs);
          m_events->Insert (ev);
        }
      if (m_events->IsEmpty () || NextTs () >= m_maxTs)
        {
          pthread_mutex_unlock (&m_messagesLock);
          m_currentTs = m_maxTs - 1;
          //m_currentTs = m_maxTs;
          SendTimeUpdateMessages ();
          pthread_mutex_unlock (&m_partitionLock);
          return;
        }
      pthread_mutex_unlock (&m_messagesLock);
      while (!m_events->IsEmpty () && NextTs () < m_maxTs)
        {
          ProcessOneEvent ();
        }
    }
  pthread_mutex_unlock (&m_partitionLock);
}