Problème de pointeur sur plusieurs threads

Version imprimable

Bonjour,

J'ai une application composé de 2 threads (render et réseau).
Afin d'éviter les appels aux fonctions render par le thread réseau, j'essaye de créer une task queue.

Mais j'ai un problème de pointeur que je n'arrive pas à comprendre.

Ma classe Main crée la task_queue (allocation dynamique). Main crée ensuite la classe network en lui passant le pointeur de la task_queue.
Jusque là tout va bien.

Ma classe network lance ensuite le thread d'écoute, et quand elle reçoit un paquet crée une tâche, et essaye de la donner à la task_queue, mais le pointeur est invalide (même pas nul, un if(ptr) crée une erreur).

Donc en code vite fait (c'est pas mon code) :
Code:

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 class Main { TaskQueue* task_queue; Network* net; Main() { task_queue = new TaskQueue(); net = new Network(task_queue); } } class Network { TaskQueue* task_queue; Network(TaskQueue* p_queue) { task_queue = p_queue; } void run() { // thread different while(true) { socket->read(buffer); if(task_queue) // <- crash task_queue->addTask(new Task(buffer)); } } }
Merci d'avance pour vos réponses.

Quand tu crées un thread, tu perds tout le contexte !!!

tu dois passer 'this' en paramètre de ton thread.

Et run deviendra :

Code:

1
2
3
4
5
6
7
8
void run(void *pParam) {  // thread different
                Network *pNet = (Network *)pParam;
		while(true) {
			socket->read(buffer);
			if(pNet->task_queue) // ca devrait marcher
				pNet->task_queue->addTask(new Task(buffer));
		}
	}

Merci pour ta réponse,

c'est en effet logique, par contre, en voulant faire la correction, j'ai remarqué que j'ai un peu trop simplifié mon problème. Le voici avec les corrections :

Code:

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
40
41
42
43
44
45
46
47
48
49
class Main {
	TaskQueue* task_queue;
	Network*   net;
	Handler*   handler;
 
	Main() {
		 task_queue = new TaskQueue();
		 handler = new Handler(task_queue);
		 net = new Network(handler);
		 net.launch();
	}
}
 
class Handler {
	TaskQueue* task_queue;
 
	Handler(TaskQueue* p_queue) {
		task_queue = p_queue;
	}
 
	void handle(buffer) {
		if(task_queue) // <- crash
			task_queue->addTask(new Task(buffer));
	}
 
}
 
class Network {
	Handler* handler;
 
	Network(Handler* p_handler) {
		handler = p_handler;
	}
 
	static void run(void* data) {  // different thread
		char buffer[1024];
		Network* this_ptr = (Network*)data;
 
		while(true) {
			this_ptr->socket->read(buffer);
			this_ptr->handler->handle(buffer);
		}
	}
 
	void launch() {
		Thread thread(run, this); // thread sfml
		thread.launch();
	}
}

Et donc, j'ai toujours le crash.

01/09/2010, 09h17
fregolo52

essaie de mettre des traces (printf "%p" ?) pour débugger et avoir les valeurs des poiteurs à différents endroits du code.
01/09/2010, 19h56
Schpitt

J'ai fini par passer à une gestion centralisée des différentes task_queue accessible statiquement, je n'ai donc plus le problème. Et je ne peux/veux plus essayer de le résoudre.

Merci quand même pour ton aide.