ofIsCurrentThreadTheMainThread (#7548)

#changelog #thread

Author: artificiel

examples/threads/threadExample/src/ofApp.cpp

@@ -4,6 +4,7 @@
 void ofApp::setup(){
 	threadedObject.setup();
 	doLock = false;
+	ofLogNotice("main thread Id") << ofGetMainThreadId();
 }
 
 //--------------------------------------------------------------
@@ -39,6 +40,12 @@ void ofApp::draw(){
 //--------------------------------------------------------------
 void ofApp::keyPressed(int key){
 	if (key == 'a'){
+		if (ofIsCurrentThreadTheMainThread()) {
+			ofLogNotice("ofApp::keyPressed") << "processed in main thread";
+		} else {
+			// will never happen but to document the branch:
+			ofLogNotice("ofApp::keyPressed") << "processed in other thread";
+		}
 		threadedObject.start();
 	}else if (key == 's'){
 		threadedObject.stop();

examples/threads/threadExample/src/threadedObject.h

@@ -51,6 +51,12 @@ class ThreadedObject: public ofThread
 	/// other tasks.
 	void threadedFunction(){
 		while(isThreadRunning()){
+			if (ofIsCurrentThreadTheMainThread()) {
+				// will never happen but to document the branch:
+				ofLogNotice("ThreadedObject::threadedFunction") << "processed in main thread";
+			} else {
+				ofLogNotice("ThreadedObject::threadedFunction") << "processed in other thread";
+			}
 			// since we are only writting to the frame number from one thread
 			// and there's no calculations that depend on it we can just write to
 			// it without locking

libs/openFrameworks/app/ofAppRunner.cpp

@@ -323,6 +323,15 @@ ofBaseApp * ofGetAppPtr(){
 	return mainLoop()->getCurrentApp().get();
 }
 
+//--------------------------------------
+std::thread::id ofGetMainThreadId() {
+	return ofGetMainLoop()->get_thread_id() ;
+}
+
+bool ofIsCurrentThreadTheMainThread() {
+	return ofGetMainThreadId() == std::this_thread::get_id();
+}
+
 //--------------------------------------
 ofAppBaseWindow * ofGetWindowPtr(){
 	return mainLoop()->getCurrentWindow().get();

libs/openFrameworks/app/ofAppRunner.h

@@ -52,6 +52,9 @@ ofBaseApp * ofGetAppPtr();
 
 void		ofExit(int status=0);
 
+bool 		ofIsCurrentThreadTheMainThread();
+std::thread::id ofGetMainThreadId();
+
 //-------------------------- time
 float 		ofGetFrameRate();
 float 		ofGetTargetFrameRate();

libs/openFrameworks/app/ofMainLoop.h

@@ -46,7 +46,12 @@ class ofMainLoop {
 
 	ofEvent<void> exitEvent;
 	ofEvent<void> loopEvent;
+	
+	std::thread::id get_thread_id() { return thread_id; };
+
 private:
+	std::thread::id thread_id { std::this_thread::get_id() };
+
 	void keyPressed(ofKeyEventArgs & key);
 	std::unordered_map<std::shared_ptr<ofAppBaseWindow>, std::shared_ptr<ofBaseApp> > windowsApps;
 	bool bShouldClose;