summaryrefslogtreecommitdiffstats
path: root/test/src/test-eventdelay.cpp
blob: a3fec34f5430bef1e5fa1a7547aa208c1c7dc26a (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
#include "uscxml/concurrency/eventqueue/DelayedEventQueue.h"

int eventCalled = 0;

#include <sstream>

static void callback(void* userData, const std::string eventId) {
//  std::cout << eventId << ": " << (const char*)userData << std::endl;
	std::cout << eventId << std::endl << std::flush;
	eventCalled++;
}

int main(int argc, char** argv) {

	using namespace uscxml;
	DelayedEventQueue* eq = new DelayedEventQueue();

	std::cout << "Starting" << std::endl;
	eq->start();
	tthread::this_thread::sleep_for(tthread::chrono::milliseconds(10));

//  eq->addEvent("foo", callback, 200, (void*)"event foo");
//  eq->addEvent("bar", callback, 400, (void*)"event bar");
//  eq->addEvent("bar", callback, 600, (void*)"event bar");
//  eq->cancelEvent("bar");
//  eq->addEvent("bar", callback, 300, (void*)"event bar");
//  eq->addEvent("baz", callback, 400, (void*)"event baz");

	for (unsigned int i = 0; i <= 2000; i += 200) {
//    eq->stop();
		std::stringstream ss;
		ss << i;
		eq->addEvent(ss.str(), callback, i, NULL);
		std::cout << "Added " << i << std::endl;
//    eq->start();
	}
	tthread::this_thread::sleep_for(tthread::chrono::milliseconds(2000));

}