blob: a336795f4a65882ff42786aa104dde1ffe858cf3 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
|
// Copyright (C) 2012 Vicente Botet
//
// Distributed under the Boost Software License, Version 1.0. (See accompanying
// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
#define BOOST_THREAD_VERSION 2
#include <boost/date_time.hpp>
#include <boost/thread/mutex.hpp>
#include <boost/thread/thread_only.hpp>
#include <iostream>
// Number should be big enough to allow context switch between threads, otherwise the bug doesn't show.
static int MAX_COUNTS;
class ItemKeeper {
public:
ItemKeeper() { }
void doSomething() {
boost::unique_lock<boost::mutex> scoped_lock(mutex);
int counts = MAX_COUNTS;
while (counts--);
}
private:
boost::mutex mutex;
};
ItemKeeper itemKeeper;
int MAX_ITERATIONS(5);
void threadFunc(int invokerID, bool& exceptionOccurred) {
try {
for (int i = 0; i < MAX_ITERATIONS; i++) {
std::cout << "Thread " << invokerID << ", iteration " << i << std::endl;
itemKeeper.doSomething();
}
} catch (...) {
exceptionOccurred = true;
}
}
int main(int argc, char* argv[]) {
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;
}
|
