Сервер на основе SwingWorker не останавливается - PullRequest
Новая
       21

Сервер на основе SwingWorker не останавливается

1 голос
/ 06 марта 2012

У меня есть логическая переменная для управления работой сервера (запуск / остановка):

приватный логический ecoute = true;

вот мой класс: 

 sw=new SwingWorker<String,Void> (){

 protected String doInBackground() throws Exception {
    try {

            server = new ServerSocket(Integer.parseInt(port.getText()));

            String str1="waiting for connexion..";
            String str2="Connexion ok";

            log.append(str1+"\n");
            PrintWriter out=null;
            BufferedReader in=null;
            Socket socClient=null;
         while(ecoute){

                socClient = server.accept();  
                    log.append(str2+"\n");
                     in = new BufferedReader(
                                    new InputStreamReader(socClient.getInputStream())
                                   );
                   out = new PrintWriter(
                     new BufferedWriter(
                        new OutputStreamWriter(socClient.getOutputStream())), 
                     true);
                    String str = in.readLine();
                    log.append(str+"\n");

         }

            in.close();
            out.close();
            socClient.close();
            return "***End Reception***";
    } catch (IOException ex) {
        Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex);
        return "***Error Reception***";
    }

       }

       protected void done(){
       String m="";
            try {
                m=get();
            } catch (InterruptedException ex) {
                Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex);
            } catch (ExecutionException ex) {
                Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex);
            }
        log.append(m+"\n");

       }
    };
   sw.execute();
  }

когда я нажимаю кнопку, чтобы передать переменную в false, чтобы мой поток вышел из бесконечного цикла, ничего не происходит: 

 private void arretReceptionActionPerformed(java.awt.event.ActionEvent evt) {


    ecoute=false;

}

Я заменил ecoute=false; на sw.calcel(true); тоже ничего нового ...

есть предложения?

1 Ответ

4 голосов
/ 06 марта 2012

Ваш ServerSocket - это то, что заставляет цикл не прерываться. Даже если «ecoute» равно false, server.accept () будет блокироваться до тех пор, пока не будет выполнено одно из следующих двух условий:

  1. Установлено соединение с ServerSocket
  2. ServerSocket закрыт.

Вам необходимо выполнить одно из этих двух действий, чтобы вызов server.accept () прекратил блокировку. Имейте в виду - если вы решите закрыть ServerSocket, IOException будет брошено. Вероятно, было бы лучше обернуть вызов server.accept () в блок try, а не оборачивать всю функцию doInBackground ().

...