threadpool-queueimpl-tests.cc File Reference

#include <scroom/threadpool.hh>
#include <iostream>
#include <boost/date_time/posix_time/posix_time.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/test/unit_test.hpp>
#include <boost/thread.hpp>
#include <scroom/semaphore.hh>
#include "helpers.hh"

Include dependency graph for threadpool-queueimpl-tests.cc:

Functions
const millisec	short_timeout (250)
const millisec	long_timeout (2000)
	BOOST_AUTO_TEST_CASE (queueimpl_jobs_get_executed)
	BOOST_AUTO_TEST_CASE (queueimpl_jobs_with_deleted_queue_can_be_scheduled_and_dont_get_executed)

Function Documentation

BOOST_AUTO_TEST_CASE() [1/2]

BOOST_AUTO_TEST_CASE

(

queueimpl_jobs_get_executed

)

{
  ThreadPool::Queue::Ptr const     queue = ThreadPool::Queue::create();
  ThreadPool::WeakQueue::Ptr const weak  = queue->getWeak();
  Semaphore                        s(0);
  ThreadPool                       t(0);
  t.schedule(clear(&s), weak);
  t.add();
  BOOST_CHECK(s.P(long_timeout));
}

Here is the call graph for this function:

BOOST_AUTO_TEST_CASE() [2/2]

BOOST_AUTO_TEST_CASE

(

queueimpl_jobs_with_deleted_queue_can_be_scheduled_and_dont_get_executed

)

{
  ThreadPool::Queue::Ptr           queue = ThreadPool::Queue::create();
  ThreadPool::WeakQueue::Ptr const weak  = queue->getWeak();
  Semaphore                        s1(0);
  Semaphore                        s2(0);
  ThreadPool                       t(0);
  queue.reset();
  t.schedule(clear(&s1), weak);
  t.schedule(clear(&s2));
  t.add();
  BOOST_CHECK(s2.P(long_timeout));
  BOOST_CHECK(!s1.try_P());
}

Here is the call graph for this function:

long_timeout()

const millisec long_timeout

(

2000

)

Referenced by BOOST_AUTO_TEST_CASE().

Here is the caller graph for this function:

short_timeout()

const millisec short_timeout

(

250

)