无法中断线程

Question

我正在实施聊天程序。每当用户点击Player.java中的“START”时，它将终止前一个Chatter线程并构建一个新的线程来启动。 Chatter线程具有用于聊天的GUI。

我通过interrupt（）方法终止Chatter线程。我认为它会在Chatter线程中设置标志，以便通过检查isInterrupted（）来终止它，但它总是为false。但它应该当我Player.java

这里调用中断（）是真的是我的代码： Player.java

public class Player implements GameConstants{ 
     /** 
     * This listener is used when the user clicks QUIT in the GUI. 
     */ 
     private class ControlListener implements ActionListener{ 

      /** 
      * This method sends QUIT to the server when the listener is triggered. 
      * @param e ActionEvent 
      */ 
      @Override 
      public void actionPerformed(ActionEvent e){  
       String cmd = ((JButton)(e.getSource())).getText(); 

       if ("START".equals(cmd)) { 

        //I interrupt the thread using this 
        if (chatThread !=null) { 
         System.err.println("before interruped"); 
         chatThread.interrupt(); 
        } 

        chatThread = new Chatter(ip,senderName); 
        chatThread.start(); 
       } 


      } 
     } 
    } 

下面是Chatter.java

public class Chatter extends Thread implements GameConstants{ 
     private JTextArea log; 
     private String senderName; 
     private DataInputStream fromServer; 
     private DataOutputStream toServer; 
     private JTextField inputField; 
     private SoundPlayer msgSound; 
     private Socket socket; 



     private class SendListener implements ActionListener{ 
      @Override 
      public void actionPerformed(ActionEvent e){ 
       String msg = inputField.getText(); 
       inputField.setText(""); 
       try { 
        toServer.writeUTF(""+(new Date())+ "\n" + senderName + ": "+msg); 
        toServer.flush(); 
       } catch(IOException ex) { 
        System.err.println(ex.getMessage()); 
       } 
      } 

     } 


     public Chatter(String ip, String senderName){ 
      this.senderName = senderName; 

      buildGUI(); 
      try{ 
       socket = new Socket(ip,CHAT_PORT); 
       fromServer = new DataInputStream(socket.getInputStream()); 
       toServer = new DataOutputStream(socket.getOutputStream()); 
      }catch(IOException e){ 
       System.out.println(e.getMessage()); 
      } 
     } 

     @Override 
     public void run(){ 
      try { 
       while(!isInterrupted()){ 
        String msg = fromServer.readUTF(); 
        report(msg); 
       } 

      } catch(IOException e) { 
       System.err.println(e.getMessage()); 
      }finally{ 
       try { 
        socket.close(); 
       } catch(Exception e) { 
       } 

      }   

     } 


     private void buildGUI(){ 
      JFrame frame = new JFrame(); 
      frame.setSize(WIDTH,HEIGHT); 
      frame.setTitle("Chat Room - " + senderName); 
      frame.setResizable(false); 
      // .... just building the GUI 

      frame.add(parentPanel); 
      frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); 
      frame.setVisible(true); 
     } 

    } 

Answer 1

当你中断一个线程，它可能会抛出InterruptedException，如果它正在等待一些IO操作或类似的。其中断标志将在抛出异常后被清除，并且将再次为假。