Discussion :

[Schpitt]

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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.

[fregolo52]

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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));
		}
	}

[Schpitt]

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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.

[fregolo52]

essaie de mettre des traces (printf "%p" ?) pour débugger et avoir les valeurs des poiteurs à différents endroits du code.

[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.