ItemKeeper() { }

void doSomething() {

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

int counts = MAX_COUNTS;

while (counts--);

}

boost::mutex mutex;

try {

for (int i = 0; i < MAX_ITERATIONS; i++) {

std::cout << "Thread " << invokerID << ", iteration " << i << std::endl;

itemKeeper.doSomething();

}

} catch (...) {

exceptionOccurred = true;

}

if (argc < 2) {

MAX_COUNTS = 5000000;

} else {

std::string valueStr(argv[1]);

bool has_only_digits = (valueStr.find_first_not_of( "0123456789" ) == std::string::npos);

if (has_only_digits) {

std::istringstream aStream(valueStr);

aStream >> MAX_COUNTS;

} else {

std::cerr << "Argument should be an integer\n";

return 1;

}

}

bool exceptionOccurred1(false);

bool exceptionOccurred2(false);

boost::thread thread1(threadFunc, 1, boost::ref(exceptionOccurred1));

boost::thread thread2(threadFunc, 2, boost::ref(exceptionOccurred2));

boost::posix_time::time_duration timeout = boost::posix_time::milliseconds(10000*100);

bool deadlockOccured(false);

//thread1.join();

//thread2.join();

if (!thread1.timed_join(timeout)) {

deadlockOccured = true;

thread1.interrupt();

}

if (!thread2.timed_join(timeout)) {

deadlockOccured = true;

thread2.interrupt();

}

if (deadlockOccured) {

std::cout << "Deadlock occurred\n";

return 1;

}

if (exceptionOccurred1 || exceptionOccurred2) {

std::cout << "Exception occurred\n";

return 1;

}

return 0;