diff --git a/src/org/openlcb/OlcbInterface.java b/src/org/openlcb/OlcbInterface.java index 5ea76045..e9329625 100644 --- a/src/org/openlcb/OlcbInterface.java +++ b/src/org/openlcb/OlcbInterface.java @@ -86,7 +86,7 @@ public void connectionActive(Connection c) { public void run() { queuedOutputConnection.run(); } - }).start(); + }, "openlcb-output-queue").start(); } }); } diff --git a/src/org/openlcb/can/CanInterface.java b/src/org/openlcb/can/CanInterface.java index 8931e753..a3ccc1fc 100644 --- a/src/org/openlcb/can/CanInterface.java +++ b/src/org/openlcb/can/CanInterface.java @@ -54,7 +54,7 @@ public CanInterface(NodeID interfaceId, CanFrameListener frameOutput) { public void run() { initialize(); } - }).start(); + }, "openlcb-if-initialize").start(); } public CanFrameListener frameInput() { return frameInput; } diff --git a/src/org/openlcb/can/impl/GridConnectInput.java b/src/org/openlcb/can/impl/GridConnectInput.java index 9105439d..d8dc325d 100644 --- a/src/org/openlcb/can/impl/GridConnectInput.java +++ b/src/org/openlcb/can/impl/GridConnectInput.java @@ -34,7 +34,7 @@ public GridConnectInput(BufferedReader input, CanFrameListener listener, Runnabl this.input = input; this.listener = listener; this.onError = onError; - new Thread() { + new Thread("openlcb-gc-input") { public void run() { threadBody(); } diff --git a/src/org/openlcb/can/impl/OlcbConnection.java b/src/org/openlcb/can/impl/OlcbConnection.java index a5f16f2a..833de16e 100644 --- a/src/org/openlcb/can/impl/OlcbConnection.java +++ b/src/org/openlcb/can/impl/OlcbConnection.java @@ -49,7 +49,7 @@ public OlcbConnection(NodeID nodeId, String } public void startConnect() { - new Thread() { + new Thread("openlcb-connect") { public void run() { connect(); } diff --git a/src/org/openlcb/cdi/swing/CdiPanel.java b/src/org/openlcb/cdi/swing/CdiPanel.java index b878c552..b6d87f27 100644 --- a/src/org/openlcb/cdi/swing/CdiPanel.java +++ b/src/org/openlcb/cdi/swing/CdiPanel.java @@ -438,7 +438,7 @@ public void run() { rep.visit(new RendererVisitor()); EventQueue.invokeLater(() -> displayComplete()); } - }).start(); + }, "openlcb-cdi-render").start(); } private void displayComplete() { diff --git a/src/org/openlcb/hub/Hub.java b/src/org/openlcb/hub/Hub.java index eab6977f..5b6f82a5 100644 --- a/src/org/openlcb/hub/Hub.java +++ b/src/org/openlcb/hub/Hub.java @@ -37,7 +37,7 @@ public Hub() { public Hub(int port) { this.port = port; // create array server thread - Thread t = new Thread() { + Thread t = new Thread("openlcb-hub-output") { public void run() { while (true) { try { diff --git a/src/org/openlcb/implementations/DatagramMeteringBuffer.java b/src/org/openlcb/implementations/DatagramMeteringBuffer.java index 5048b733..7e9624b3 100644 --- a/src/org/openlcb/implementations/DatagramMeteringBuffer.java +++ b/src/org/openlcb/implementations/DatagramMeteringBuffer.java @@ -88,7 +88,7 @@ public void put(Message msg, Connection toUpstream) { private void datagramComplete() { currentMemo = null; - new Thread(new Consumer(queue)).start(); + new Thread(new Consumer(queue), "openlcb-datagram-queue").start(); } class ReplyHandler extends AbstractConnection {