Changeset View

Standalone View

Show First 20 Lines • Show All 196 Lines • ▼ Show 20 Lines	BOOST_AUTO_TEST_CASE(singlethreadedscheduler_ordered) {
// required here		// required here
int counter1 = 0;		int counter1 = 0;
int counter2 = 0;		int counter2 = 0;

// just simply count up on each queue - if execution is properly ordered		// just simply count up on each queue - if execution is properly ordered
// then the callbacks should run in exactly the order in which they were		// then the callbacks should run in exactly the order in which they were
// enqueued		// enqueued
for (int i = 0; i < 100; ++i) {		for (int i = 0; i < 100; ++i) {
queue1.AddToProcessQueue([i, &counter1]() { assert(i == counter1++); });		queue1.AddToProcessQueue([i, &counter1]() {
		bool expectation = i == counter1++;
queue2.AddToProcessQueue([i, &counter2]() { assert(i == counter2++); });		assert(expectation);
		});

		queue2.AddToProcessQueue([i, &counter2]() {
		bool expectation = i == counter2++;
		assert(expectation);
		});
}		}

// finish up		// finish up
scheduler.stop(true);		scheduler.stop(true);
threads.join_all();		threads.join_all();

BOOST_CHECK_EQUAL(counter1, 100);		BOOST_CHECK_EQUAL(counter1, 100);
BOOST_CHECK_EQUAL(counter2, 100);		BOOST_CHECK_EQUAL(counter2, 100);
}		}

BOOST_AUTO_TEST_SUITE_END()		BOOST_AUTO_TEST_SUITE_END()