Problématiques de process et pipe

c'est bon j'avais oublier de flusher dans les threads :D

voici la solution :

principal :

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
 
import java.io.*;
 
public class ihm {
 
  public static void main(String args[]) throws InterruptedException
  {
    String s = null, st;
 
    try 
      { 
        // Creation du processus
        Process p = Runtime.getRuntime().exec("./dial");
 
        // Creation et lancement des threads de communication
        Thread t1 = new write(p), t2 = new read(p);
        t1.start();
        t2.start();
 
        // On attends la fin du dialogue pour quitter l'application
        t1.join();
        t2.join();
        System.exit(0);
 
        }
    catch (IOException e) {
      System.out.println("exception happened - here's what I know: ");
      e.printStackTrace();
      System.exit(-1);
    }
  }
}

write :

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
 
import java.io.*;
 
public class write extends Thread
{
  Process p;
  write(Process p)
  {
    this.p = p;
  }
 
  public void run() {
    try {
      // Creation du flux d'ecriture
      String st;
      BufferedWriter stdOutput = new BufferedWriter(new 
                   OutputStreamWriter(p.getOutputStream()));
 
      // Boucle test
      int i = 0;
      while (i<100)
        {
          // Affichage sur l'ecran
          System.out.println("java -> " + i);
          st = ""+i+"\n";
 
          // MAJ
          i++;
 
          // Envoie sur le PIPE
          stdOutput.write(st, 0, st.length());
          stdOutput.flush();
        }
 
      // Declaration de fin de com.
      st ="fin\n";
      stdOutput.write(st, 0, st.length());
      stdOutput.flush();
    }
    catch (IOException ioe) {
      ioe.printStackTrace();
    }
  }
}

read :

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
 
import java.io.*;
 
public class read extends Thread
{
  Process p;
  read(Process p)
  {
    this.p = p;
  }
 
  public void run()
  {
    try 
      {
        // Initialisation du flux de reception
        String s = "";
        BufferedReader stdInput = new BufferedReader(new 
           InputStreamReader(p.getInputStream()));
 
 
        while (((s = stdInput.readLine()) != null) && (s.indexOf("str = fin") != -1)) {
          System.out.println("C-> " + s);
        }
 
      }
    catch (IOException ioe) 
      {
        ioe.printStackTrace();
      }
  }
}