Android/Java實現Runable進入無限循環

Question

我使用以下代碼連接兩個Android設備P2P。問題是，當服務器從客戶端接收數據時，其Thread/Runable不會停止。

請建議我一種方法來阻止/強迫它進入無限循環。

下面是一段代碼，我用我的服務器活動時間：

 public class ServerThread implements Runnable { 
      private volatile boolean keepGoing = true; 

       public void requestStop() { 
        keepGoing = false; 
       } 
       public void run() { 
        try { 
         if (SERVERIP != null) { 
          handler.post(new Runnable() { 
           @Override 
           public void run() { 
         serverStatus.setText("Listening on IP: " + SERVERIP); 
        } 
       }); 
       serverSocket = new ServerSocket(SERVERPORT); 
       while (true) { 
        // listen for incoming clients 
        Socket client = serverSocket.accept(); 
        handler.post(new Runnable() { 
         @Override 
         public void run() { 
          serverStatus.setText("Connected."); 
         } 
        }); 

        try { 
         BufferedReader in = new BufferedReader(new    
          InputStreamReader(client.getInputStream())); 
         line = null; 
         while ((line = in.readLine()) != null) { 
          Log.d("ServerActivity", line); 
          handler.post(new Runnable() { 
           @Override 
           public void run() { 

            serverStatus.setText(line); 


            Log.d("IP recevied", line); 
            requestStop(); 
            //finish(); 

            //Intent i = new Intent(ServerActivity.this, 
             //ClientActivity.class); 
            //startActivity(i); 
            //serverStatus.setText(line); 
            // do whatever you want to the front end 
            // this is where you can be creative 
           } 
          }); 
         } 

         break; 
        } catch (Exception e) { 
         handler.post(new Runnable() { 
          @Override 
          public void run() { 
           serverStatus.setText("Oops. Connection interrupted. 
             Please reconnect your phones."); 
          } 
         }); 
         e.printStackTrace(); 
        } 
       } 
      } else { 
       handler.post(new Runnable() { 
        @Override 
        public void run() { 
         serverStatus.setText("Couldn't detect internet connection."); 
        } 
       }); 
         } 
           } catch (Exception e) { 
            handler.post(new Runnable() { 
            @Override 
          public void run() { 
        serverStatus.setText("Error"); 
          } 
         }); 
         e.printStackTrace(); 
        } 
       } 
      } 

編輯：

while (keepGoing) { 
     // listen for incoming clients 
     Socket client = serverSocket.accept(); 
     handler.post(new Runnable() { 
      @Override 
      public void run() { 
       serverStatus.setText("Connected."); 
      } 
     }); 

     try { 
      BufferedReader in = new BufferedReader(new    
        InputStreamReader(client.getInputStream())); 
      line = null; 
      while (((line = in.readLine()) != null) && keepGoing) { 
       Log.d("ServerActivity", line); 
       handler.post(new Runnable() { 
        @Override 
        public void run() { 

         serverStatus.setText(line); 


         Log.d("IP recevied", line); 
         requestStop(); 
         //finish(); 

         //Intent i = new Intent(ServerActivity.this, 
          //ClientActivity.class); 
         //startActivity(i); 
         //serverStatus.setText(line); 
         // do whatever you want to the front end 
         // this is where you can be creative 
        } 
       }); 
      } 

Answer 1

我認爲問題是，即使你信號的服務器停止，它仍然停留在調用serverSocket.accept();，等待其他客戶端連接。你應該做的也是關閉套接字在停止方法：

public void requestStop() { 
     keepGoing = false; 
     serverSocket.close(); 
} 

迫使代碼拋出一個IOException，然後重新檢查while條件和退出。

Answer 2

爲什麼你對此有何評論線

//finish(); 

一旦連接成立？

因爲你永遠不結束，一旦你連接你有一個無限循環