{

for (int i = 0; i < 5; ++i)

{

if (gen_barrier.wait())

{

boost::unique_lock<boost::mutex> lock(mutex);

global_parameter++;

}

}

{

boost::thread_group g;

global_parameter = 0;

try

{

for (int i = 0; i < N_THREADS; ++i)

g.create_thread(&barrier_thread);

g.join_all();

}

catch(...)

{

BOOST_TEST(false);

g.interrupt_all();

g.join_all();

//throw;

}

BOOST_TEST(global_parameter==5);

{

test_barrier();

return boost::report_errors();