Serveur

import java.net.*;
import java.io.*;

public class ServerThread extends Thread {
  static public boolean bRun = true ;
  Recepteur recepteur ;

  public static void main(String argv[]) {
    ServerThread st = new ServerThread() ;
    st.start() ;
  }

  public ServerThread() {
    recepteur = new Recepteur() ;
    recepteur.start() ;
  }

  public void run() {
    while( bRun == true ) {
      System.out.println("Alive") ;
      try {
        Thread.sleep(1000) ; }
      catch(Exception e) { } }
    recepteur.fin() ;
    System.exit(0) ;
    }
}

import java.net.* ;
import java.io.* ;

public class Recepteur extends Thread {
  private ServerSocket s = null ;
  private boolean bRun ;

  public Recepteur() {
    bRun = false ;
    setDaemon(true) ;
    }

  public void run() {
    try {
      s = new ServerSocket(5555) ; }
    catch(IOException e) { } ;
    if ( s != null ) {
      bRun = true ;
      while ( bRun ) {
        System.out.println("Listening") ;
        try {
          Socket newS = s.accept() ;
          ...
          newS.close() ; }
        catch(IOException e) { } ;
        try {
          Thread.sleep(100) ; }
        catch(Exception e) { } } }
    }

  public void fin() {
    bRun = false ;
    }
  }