Слушатель сокета - УБИЙСТВО моего процессора, как улучшить производительность моего кода?

Question

Я реализовал прослушиватель Socket для чтения данных, отправленных с GPS, но он достигает 90% моего процессора. Я знаю, что это мой код, вызывающий это, но я не могу видеть, где.

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

public class PortToDB { 

    ServerSocket serverSocket = null; 

    public void listenSocket(){ 
     try{ 
      serverSocket = new ServerSocket(50000); 
     } catch (IOException e) { 
      System.out.println("Could not listen on port 50000. " + e); 
      System.exit(-1); 
     } 

     while(true){ 
      GPSData gd; 
      try{ 
       gd = new GPSData(serverSocket.accept()); 
       Thread t = new Thread(gd); 
       t.start(); 
      } catch (IOException e) { 
       System.out.println("Accept failed: 50000. " + e); 
       System.exit(-1); 
      } 
     } 
    } 

    public static void main(String[] args) {  
     PortToDB portToDb = new PortToDB(); 
     portToDb.listenSocket(); 
    } 
} 

Это мой Runnable Класс:

class GPSData implements Runnable { 

    private Socket client; 
    DBHandler dbhandler = new DBHandler(); 

    GPSData(Socket client) { this.client = client; } 

    public void run(){ 
     String line; 
     BufferedReader in = null; 

    try{ 
     in = new BufferedReader(new InputStreamReader(client.getInputStream())); 
    } catch (IOException e) { 
     System.out.println("in or out failed"); 
     System.exit(-1); 
    } 

    while(true){ 
     try{ 
      if((line = in.readLine()) != null){ 
       dbhandler.dbInsert(line); 
      } 
     } catch (IOException e) { 
      System.out.println("Read failed"); 
      System.exit(-1); 
     } 
    } 
    } 
} 

Answer 1

Если readLine() возвращает null, вы должны закрыть розетку, выйти из цикла чтения и забыть об этом клиенте. Вы вращаетесь в EOS.

Answer 2

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

private ExecutorService executor = Executors.newFixedThreadPool(15); 

// ... 

gd = new GPSData(serverSocket.accept()); 
executor.submit(gd); 

Таким образом, вы исключите накладные расходы на создание неограниченных потоков во время получения запросов и вместо этого создает ограниченные потоки даже до открытия порта сокета для приема запросов.

---

Кроме того, как сказал @EJB, выход клиента для цикла при каждом приеме null от readLine() как индикатор конца потока (ЭОС).

Answer 3

Спасибо всем, кто ответил на мой вопрос.

Я решил эту проблему путем объединения Eng.Fouad-х и предложение EJP в:

Это то, что я изменил в своем коде:

Исполнитель:

private ExecutorService executor = Executors.newFixedThreadPool(15); 

    try{ 
     gd = new GPSData(serverSocket.accept()); 
     executor.submit(gd); 
    } 

Циклическое управление:

try{    
     while((line = in.readLine()) != null){   
     dbhandler.dbInsert(line); 
     } 
    } 

Теперь процесс остается на 0% :).

Спасибо EJP и Eng.Fouad.