From 52918580bdb1dd4c4f8810e0de8f036949dde450 Mon Sep 17 00:00:00 2001
From: serega6531 <serega6531@yandex.ru>
Date: Fri, 13 Mar 2020 23:38:02 +0300
Subject: [PATCH] =?UTF-8?q?=D0=A0=D0=B5=D1=84=D0=B0=D0=BA=D1=82=D0=BE?=
 =?UTF-8?q?=D1=80=D0=B8=D0=BD=D0=B3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ru/serega6531/packmate/PcapWorker.java    | 22 +++++++++----------
 1 file changed, 10 insertions(+), 12 deletions(-)

diff --git a/src/main/java/ru/serega6531/packmate/PcapWorker.java b/src/main/java/ru/serega6531/packmate/PcapWorker.java
index 12e12e4..5a981ca 100644
--- a/src/main/java/ru/serega6531/packmate/PcapWorker.java
+++ b/src/main/java/ru/serega6531/packmate/PcapWorker.java
@@ -77,18 +77,16 @@ public class PcapWorker implements PacketListener {
         BasicThreadFactory factory = new BasicThreadFactory.Builder()
                 .namingPattern("pcap-worker-loop").build();
         ExecutorService loopExecutorService = Executors.newSingleThreadExecutor(factory);
-        loopExecutorService.execute(() -> {
-            try {
-                log.info("Intercept started");
-                pcap.loop(-1, this);   //  использовать другой executor?
-            } catch (InterruptedException ignored) {
-                Thread.currentThread().interrupt();
-                // выходим
-            } catch (Exception e) {
-                log.error("Error while capturing packet", e);
-                stop();
-            }
-        });
+        try {
+            log.info("Intercept started");
+            pcap.loop(-1, this, loopExecutorService);
+        } catch (InterruptedException ignored) {
+            Thread.currentThread().interrupt();
+            // выходим
+        } catch (Exception e) {
+            log.error("Error while capturing packet", e);
+            stop();
+        }
     }
 
     @PreDestroy