mirrors/mongodb
mirrors/mongodb
0
0
Fork 0
mirror of https://github.com/mongodb/mongo.git synced 2024-12-01 09:32:32 +01:00
Code Issues Releases Activity

slightly better thread test framework prep for future stuff nothing much for now

Browse Source
This commit is contained in:
dwight 2011-02-24 22:01:09 -05:00
parent 7bf96ac92b
commit 201d0f5f34
1 changed files with 8 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
dbtests/threadedtests.cpp
View File

@ -33,8 +33,8 @@ namespace ThreadedTests {
class ThreadedTest {
public:
virtual void setup() {} //optional
virtual void subthread() = 0;
virtual void validate() = 0;
virtual void subthread(int remaining) = 0; // each thread whatever test work you want done
virtual void validate() = 0; // after work is done
static const int nthreads = nthreads_param;
@ -48,12 +48,11 @@ namespace ThreadedTests {
private:
void launch_subthreads(int remaining) {
if (!remaining) return;
boost::thread athread(boost::bind(&ThreadedTest::subthread, this));
if (!remaining)
return;
boost::thread athread(boost::bind(&ThreadedTest::subthread, this, remaining));
launch_subthreads(remaining - 1);
athread.join();
}
};
@ -76,7 +75,7 @@ namespace ThreadedTests {
virtual void setup() {
mm = new MongoMutex("MongoMutexTest");
}
virtual void subthread() {
virtual void subthread(int) {
Client::initThread("mongomutextest");
sleepmillis(0);
for( int i = 0; i < N; i++ ) {
@ -139,7 +138,7 @@ namespace ThreadedTests {
static const int iterations = 1000000;
AtomicUInt target;
void subthread() {
void subthread(int) {
for(int i=0; i < iterations; i++) {
//target.x++; // verified to fail with this version
target++;
@ -170,7 +169,7 @@ namespace ThreadedTests {
public:
MVarTest() : target(0) {}
void subthread() {
void subthread(int) {
for(int i=0; i < iterations; i++) {
int val = target.take();
#if BOOST_VERSION >= 103500