From 2262c9c81fee46f21b3f1f2f3441cdfd41cb1f64 Mon Sep 17 00:00:00 2001 From: Vitaly Takmazov Date: Mon, 1 Aug 2016 16:43:39 +0300 Subject: www: Thread -> ExecutorService --- juick-www/src/main/java/com/juick/www/Main.java | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) (limited to 'juick-www/src/main') diff --git a/juick-www/src/main/java/com/juick/www/Main.java b/juick-www/src/main/java/com/juick/www/Main.java index e3457323..d8096ff4 100644 --- a/juick-www/src/main/java/com/juick/www/Main.java +++ b/juick-www/src/main/java/com/juick/www/Main.java @@ -37,6 +37,8 @@ import java.net.Socket; import java.net.URLEncoder; import java.util.Objects; import java.util.Properties; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; /** * @@ -64,6 +66,7 @@ public class Main extends HttpServlet implements Stream.StreamListener { SignUp signup = new SignUp(); Settings settings = new Settings(); RSS rss = new RSS(); + ExecutorService executorService = Executors.newSingleThreadExecutor(); @Override public void init() throws ServletException { @@ -98,8 +101,14 @@ public class Main extends HttpServlet implements Stream.StreamListener { } } + @Override + public void destroy() { + executorService.shutdownNow(); + super.destroy(); + } + public void setupXmppComponent(final JID componentJid, final String password) { - Thread thr = new Thread(() -> { + executorService.submit(() -> { try { Socket socket = new Socket("localhost", 5347); xmpp = new StreamComponent(componentJid, socket.getInputStream(), socket.getOutputStream(), password); @@ -109,7 +118,6 @@ public class Main extends HttpServlet implements Stream.StreamListener { log("XMPP is not initialized"); } }); - thr.start(); } @Override -- cgit v1.2.3