Discussion :

[Viduc]

Bonsoir

Je souhaiterais savoir s'il est possible d'accéder à un objet lancer dans un thread.

je m'explique, j'ai une class C_Chat_Emission qui étend la class Thread:

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
 
package CONTROLEUR;
 
import java.io.IOException;
import java.io.PrintWriter;
import java.util.Scanner;
 
public class C_Chat_Emission extends Thread
    {
    private PrintWriter out;
    private String message = null;
    private Scanner sc = null;
 
    public C_Chat_Emission(PrintWriter out) 
        {this.out = out;}
 
    public void run() 
        {
        sc = new Scanner(System.in);
 
        while(true)
            {
            System.out.println("Votre message :");
            this.message = this.sc.nextLine();
            this.sendMessage(this.message);
            //this.out.println(this.message);
            //this.out.flush();
            }
        }
 
    /**
     * Envoie un message au serveur
     * @param String message 
     */
    public void sendMessage(String message)
        {
        this.out.println(message);
        this.out.flush();
        }
    }

je lance mon thread depuis un autre contrôleur:

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
50
 
package CONTROLEUR;
 
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
 
public class C_Chat extends Thread
    {
    private Socket socket;
    private PrintWriter out = null;
    private BufferedReader in = null;
    private Thread threadEmission, threadReception;
    private Boolean active = true;
 
    public C_Chat(Socket s)
        {this.socket = s;}
 
    public void run() 
        {
        try 
            {
            this.out = new PrintWriter(this.socket.getOutputStream());
            this.in = new BufferedReader(new InputStreamReader(this.socket.getInputStream()));
 
            this.threadEmission = new Thread(new C_Chat_Emission(this.out));
            this.threadEmission.start();
            this.threadReception = new Thread(new C_Chat_Reception(this.in));
            this.threadReception.start();
 
            while(this.active)
                {
                if(!this.threadReception.isAlive())
                    {
                    System.out.println("interruption du thread: "+this.threadEmission.getName());
                    this.threadEmission.interrupt();
                    System.out.println("fermeture de la socket: "+this.socket.toString());
                    this.socket.close(); 
                    this.active = false; 
                    }
                }
            System.out.println("interruption du thread: "+this.getName());
            this.interrupt();
            } 
        catch (IOException e) 
            {System.err.println("Le serveur distant s'est déconnecté !");}
        }
    }

Je souhaiterais une fois lancé pouvoir agir sur mon objet, par exemple utiliser la méthode

Code :

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

public void sendMessage(String message)

mais je ne vois pas comment faire.

J'ai testé :

Code :

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

1
2
 
this.threadEmission.sendMessage("test");

mais comme je m'y attendais ça ne fonctionne pas. Je ne trouve rien de précis sur ce sujet sur le net...

Si quelqu'un a une piste une idée ...

[mohamine1989]

Slt.
Je pense que les pipe sont une solution a ton problème (communication entre thread).

[wax78]

Qu'est-ce qui ne fonctionne pas au juste ? Parce que je ne vois pas pourquoi

Code :

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

this.threadEmission.sendMessage("test");

ne "marcherait" pas.

A mon avis tu n'as pas vu ton erreur qui te pousse a cette question. A savoir ceci.

Code :

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

this.threadEmission = new Thread(new C_Chat_Emission(this.out));

Qui n'a pas lieu d'être car C_Chat_Emission extends thread. Donc :

Code :

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

this.threadEmission = new C_Chat_Emission(this.out);

me semble plus approprié et t'exposera les methode de la classe C_Chat_Emission.

[Viduc]

Merci pour vos réponses, je pense en effet que ton hypothèse est la bonne wax78... je test ça ce soir (dès fois quand c'est gros comme ça on ne voit rien )

PS: j'aime bien ton avatar très Floydien

[wax78]

Parfois un regard extérieur fait apparaitre l'évidence ca m'arrive souvent aussi. N'hésite pas si ce n'était pas la bonne hypothèse à revenir.

Oui c'est un ancien rendus 3D que j'avais fait a l'époque, étant obnubilé par cette "aberration chromatique" floydienne (et les possibilité des raytracer), l'image originale doit trainer par ici

[hwoarang]

mais comme je m'y attendais ça ne fonctionne pas. Je ne trouve rien de précis sur ce sujet sur le net...

Quand tu poses une question de ce type, c'est toujours bien de dire quelle est l'erreur exacte parce que ca creve pas toujours les yeux. Mais dons ton cas, threadEmission est un objet de la classe Thread. Or, cette classe ne possède pas de méthode public void sendMessage(String message). Je suppose donc que ton erreur est une erreur de compilation.
Concernant le this.threadEmission = new Thread(new C_Chat_Emission(this.out));, comme soulevé par wax78, c'est inutile puisque C_Chat_Emission est deja de type Thread. Mais ce n'est pas la cause de ton probleme car Thread est un Runnable donc ca devrait marcher quand meme.
Pour pouvoir accéder à la fonction sendMessage, il faut aussi changer le type de threadEmission par C_Chat_Emission (pareil pour threadReception).

Bref, pour résumer, il y a donc 2 choses à faire :
- changer le type de threadEmission et threadReception par leur type respectif
- Ne pas utiliser un Thread inutile pour lancer ceux-ci

[mohamine1989]

Vous m'excuseraient si je me trompe, mais dans le cas ou plusieurs processus sont lancés, chacun obtient ses ressources, mais ils ne peuvent communiquer entre eux (envoyer et recevoir des données entre eux) qu'a travers des protocoles, et les pipes en font partie.
Cordialement Amine.

[wax78]

Pour des processus c'est fort possible d'utiliser les pipes oui (ou une socket, ou des mémoire partagées etc), mais ici ce sont des threads en l'occurence.

Un simple échange mémoire, s'il est fait de manière a éviter les problèmes de concurrence, peux fonctionner sans devoir sortir de gros moyen.

Une simple list synchronisée marche par exemple.

Tu pourrais aussi faire par socket si l'envie t'en disait.

[mohamine1989]

Je vais tester, en tous cas, merci beaucoup pour l'info
Bonne chance

[mohamine1989]

J'ai pas encore manipuler des threads ou des processus en JAVA, mais en c, que ça soit une communication entre thread, ou entre processus, il faut des protocoles.
En tous cas, je vais tester et merci beaucoup

[Viduc]

Merci pour toutes vos réponses.

Bref, pour résumer, il y a donc 2 choses à faire :
- changer le type de threadEmission et threadReception par leur type respectif
- Ne pas utiliser un Thread inutile pour lancer ceux-ci

C'était bien ça le souci, j'ai donc modifié les types et supprimer les thread qu'il y avait en trop et ça fonctionne impec

pour info j'utilise un groupe de thread pour connecter mes clients et je type (setName) chaque thread à l'intérieur du groupe pour m'y retrouver et ça fonctionne nickel

merci encore