Java Sockets listener

Question

Было бы целесообразным использовать поток для получения объектов, полученных с помощью InputStream сокета, а затем добавить их в ConcurrentLinkedQueue, чтобы они могли быть доступны из основного потока без блокировки во входном цикле опроса?

private Queue<Packet> packetQueue = new ConcurrentLinkedQueue<Packet>(); 
private ObjectInputStream fromServer; //this is the input stream of the server 
public void startListening() 
{ 
    Thread listeningThread = new Thread() 
    { 
     public void run() 
     { 
      while(isConnected()) //check if the socket is connected to anything 
      { 
       try { 
        packetQueue.offer((Packet) fromServer.readObject()); //add packet to queue 
       } catch (ClassNotFoundException e) { 
        e.printStackTrace(); 
       } catch (IOException e) { 
        e.printStackTrace(); 
       } 
      } 
     } 
    }; 
    listeningThread.start(); //start the thread 
} 

public Packet getNextPacket() 
{ 
    return packetQueue.poll(); //get the next packet in the queue 
} 

Answer 1

Это зависит от того, что вам нужно сделать с этим объектом, который вы будете использовать в основной теме.

Если потребуется какое-то время для его обработки или если оно будет использоваться много раз, чем вы можете поместить его в очередь или в другой класс, который будет удерживать этот объект для вас, но если время, необходимое для его обработки, вам и вам не нужен этот объект дальше после обработки, вам действительно не нужно использовать очередь.

Об использовании ConcurrentQueue тоже может потребоваться заказ? вам нужен гарантированный синхронизм между чтением и записью?

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

Но «быть соответствующим» трудно ответить, потому что зависит от того, что вам нужно делать с этими объектами и как вы справитесь с этим.