#include "THCCommand.h" using namespace ThreadCommand; //THCCommand have retain count likely objective - c class UserCommand : public THCCommand { public: virtual bool Init(void* _ptr) { sleep(1); std::cout << "Init " << pthread_self() << "\n"; //if return false recall //if return true dont call this function again return true; } virtual bool Run(void* _ptr) { sleep(1); std::cout << "Run " << pthread_self() << "\n"; //if return false recall //if return true dont call this function again //first call raise at Init function return true return true; } virtual bool Clean(void* _ptr) { sleep(1); std::cout << "Clean " << pthread_self() << "\n"; //if return false recall //if return true dont call this function again, destruct class //first call raise at Run function return true return true; } } class UserEvent : public THCEvent { public: UserEvent() { //thread_id, priority, ... //if you want thread count, more regist category with another thread_id THCManager::Share()->SetCategory("thread_id", 0.1, NULL, NULL, NULL); } virtual ~UserEvent() { //if destruct, delete registed command } //tag is command user id virtual void CompleteCommand(std::string _category, std::string _tag, THCCommand* _command) { UserCommand* _user_command = (UserCommand*)_command; //raise at main thread std::cout << "CompleteCommand " << pthread_self() << "\n"; } } //run in main thread please void test(void) { UserEvent event; //regist command with thread_id //user_command is tag about command event.Run("thread_id", "user_command", new UserCommand()); while(true) { //CompleteCommand function caller THCManager::Share()->Update(); sleep(1); std::cout << "main loop " << pthread_self() << "\n"; } }