Is it possible to close connection if any exception or assertion failure occurs in main thread? #1320

Activity

1. PhilipRoman commented on Mar 29, 2023

   

   PhilipRoman

   on Mar 29, 2023

   Collaborator

   More actions

   Can you please clarify your problem? What do you mean by "main thread"? If possible, add a small code example of what you're trying to achieve.
2. Elvintest commented on Apr 10, 2023

   

   Elvintest

   on Apr 10, 2023

   Last edited by Elvintest

   Author

   More actions

   Sorry for a long pong of my side, practically i meant such cases: lets say we have such listener

      @Override
       public void onMessage(String message) {
           System.out.println("got: " + message); //temporary stdOut
           JsonNode treePackage;
           try {
               treePackage = objectMapper.readTree(message);
           } catch (JsonProcessingException e) {
               throw new RuntimeException(e);
           } 
   

   If any Exception occurs in this block main thread of java program stops, but one of these internal threads in transport continues to be alive:

           /**
     * The thread to write outgoing message
     */
    private Thread writeThread;
   
    /**
     * The thread to connect and read message
     */
    private Thread connectReadThread;
   

   I had solved my issue for destroying all threads by changing main logic of my programm, but i was wondering if there is any handler for shutting down all internal threads if i want it.Does close() function destroy both treads for reading and writing?
3. PhilipRoman commented on Apr 16, 2023

   

   PhilipRoman

   on Apr 16, 2023

   Collaborator

   More actions

   I would just catch the exception and call close(), it will correctly shut down all threads belonging to the client.