POSIX-Threads in C++

[Lateralus]

Hi

Ich würde gerne pthreads in C++ verwenden, habe aber Probleme mit der Definition der Funktionen, welche von pthread_create() aufgerufen werden sollen:

Beispiel:
pthread.cpp:

#include <iostream.h>
#include <unistd.h>
#include <pthread.h>

class Test{
	private:
	void *do_something_else(void *arg);
	
	public:
	
	void do_something();
};

void Test::do_something(){
	pthread_t thread1;
	
	pthread_create(&thread1, NULL, do_something_else, NULL);
	sleep(20);
	pthread_kill(thread1, SIGTERM);
}

void *Test::do_something_else(void *arg){
	while(1){
		cout << "thread sleeps...\n";
		sleep(3);
	}
}

Kompilieren:

g++ -Wno-deprecated pthread.cpp 
pthread.cpp: In member function `void Test::do_something()':
pthread.cpp:17: error: argument of type `void*(Test::)(void*)' does not match `void*(*)(void*)'

Wie genau müsste die Definition der Funktion statt

void *Test::do_something_else(void *arg){
...
}

aussehen?

 

[Cédric]

Das geht so nicht ganz: C++ Methoden haben andere Signaturen als C Funktionen - somit "erkennt" pthread_create() die übergebene Methode nicht. Du kannst entweder statische Methoden verwenden, das sollte gehen, oder unter http://www.linuxdocs.org/HOWTOs/C++Programming-HOWTO-24.html schauen.

Noch besser wäre wohl, die Boost Library zu verwenden - sie bietet eine O.O. Threads Implementierung: http://www.boost.org/doc/html/threads.html

Ich hoffe, das hilft dir weiter.

Cédric

 

[Vincent Vega]

pthread_create(&thread1, NULL, &do_something_else, NULL);

Du willst ja die Adresse der Funktion übergeben. Aber dann wirst Du sehn dass der Compiler sich beklagt von wegen "ISO C++ forbids taking address of non-static function" oder so ähnlich. Also musst Du die Methode do_something_else noch als "static" deklarieren.

 

[Lateralus]

Hi

Eine static-Deklaration fällt aus, weil ich auf nicht-statische Daten zugreife.

Danke für die Hinweise.

 

[gripmaster]

ich bin mir zwar nicht sicher, aber wenn die Methode do_something_else() ein Mitglied der Klasse "test" ist und sie als Thread-Funktion verwenden willst, müsst sie eigentlich static sein, da es sonst Probleme mit dem "this"-Zeiger gibt.

Alternativ könntest du die Methoder außerhalb der Klasse definieren.


gruß,
grips

 

[Vincent Vega]

Dann musst Du einen Wrapper um die Thread Routine machen. Der übergibst Du dann this als Argument via pthread_create(). Dann machst Du einen cast auf ein Objekt Deiner Klasse und rufst die eigentliche Thread Routine auf.

Ich versuch mich mal kurz, ohne den Compiler zu bemühen:

class threaded {
  private:
    pthread_t thread;
    void *thread_routine(void);
    static void *thread_routine_wrapper(void *);
  (....)
};

static void
threaded::thread_routine_wrapper(void *arg) {
  threaded *ptr = (threaded *)arg;

  return (ptr->thread_routine());
}

Und irgendwo machst Du dann:

pthread_create(&thread, NULL, &thread_routine_wrapper, this);

Wenn Du den Thread im Konstruktor erzeugst kannst Du unabhängig agierende Objekte schaffen, quasi jedes im eigenen Thread.