threadpool-destruction-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/function-additor.hh>
#include <scroom/semaphore.hh>
#include "helpers.hh"

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

Functions
const millisec	short_timeout (250)
const millisec	long_timeout (2000)
	BOOST_AUTO_TEST_CASE (destroy_threadpool_with_nonempty_queue)
	BOOST_AUTO_TEST_CASE (destroy_threadpool_with_nonempty_queue_with_completeAllJobsBeforeDestruction_true)

Function Documentation

BOOST_AUTO_TEST_CASE() [1/2]

BOOST_AUTO_TEST_CASE

(

destroy_threadpool_with_nonempty_queue

)

{
  ThreadPool::Ptr pool = ThreadPool::create(1);
  Semaphore       guard(0);
  Semaphore       a(0);
  Semaphore       b(0);
  Semaphore       c(0);
 
  pool->schedule(clear(&a) + pass(&b));
  pool->schedule(clear(&c));
 
  // Give the thread some time to start the job
  a.P();
 
  boost::thread t(pass(&guard) + destroy(pool));
  pool.reset();
  guard.V();
 
  // Thread t destroys the threadpool without waiting for ThreadPool
  // jobs to finish. Hence, it should terminate immediately, even
  // though the threadpool is blocked on pass(&b)
  BOOST_CHECK(t.timed_join(long_timeout));
  BOOST_REQUIRE(boost::thread::id() == t.get_id());
  b.V();
  BOOST_CHECK(!c.P(long_timeout));
}

Here is the call graph for this function:

BOOST_AUTO_TEST_CASE() [2/2]

BOOST_AUTO_TEST_CASE

(

destroy_threadpool_with_nonempty_queue_with_completeAllJobsBeforeDestruction_true

)

{
  ThreadPool::Ptr pool = ThreadPool::create(1, true);
  Semaphore       guard(0);
  Semaphore       a(0);
  Semaphore       b(0);
  Semaphore       c(0);
 
  pool->schedule(clear(&a) + pass(&b));
  pool->schedule(clear(&c));
 
  // Give the thread some time to start the job
  a.P();
 
  boost::thread t(pass(&guard) + destroy(pool));
  pool.reset();
  guard.V();
 
  // Thread t destroys the threadpool without waiting for ThreadPool
  // jobs to finish. Hence, it should terminate immediately, even
  // though the threadpool is blocked on pass(&b)
  BOOST_CHECK(t.timed_join(long_timeout));
  BOOST_REQUIRE(boost::thread::id() == t.get_id());
  b.V();
  BOOST_CHECK(c.P(long_timeout));
}

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

)