From aab743aa2f78203c27b91c95a10693995de44a35 Mon Sep 17 00:00:00 2001 From: WickedJack99 Date: Mon, 1 Apr 2024 17:21:34 +0200 Subject: [PATCH] Main program --- src/main/java/java/src/Main.java | 44 ++++++++++++++++++++++++++++++++ 1 file changed, 44 insertions(+) create mode 100644 src/main/java/java/src/Main.java diff --git a/src/main/java/java/src/Main.java b/src/main/java/java/src/Main.java new file mode 100644 index 0000000..a9039d2 --- /dev/null +++ b/src/main/java/java/src/Main.java @@ -0,0 +1,44 @@ +/** + * @author Aaron Moser + */ + +package java.src; + +import java.net.DatagramSocket; +import java.net.SocketException; +import java.src.Input.InputThread; +import java.src.Receiving.ReceiverThread; +import java.src.Receiving.ReceivingQueue; +import java.src.Sending.SenderThread; +import java.src.Sending.SendingQueue; + +public class Main { + public static void main(String[] args) { + try { + DatagramSocket datagramSocket = new DatagramSocket(5000); + + SendingQueue sendingQueue = new SendingQueue(); + ReceivingQueue receivingQueue = new ReceivingQueue(); + + ReceiverThread receiverThread = new ReceiverThread(datagramSocket, receivingQueue); + receiverThread.start(); + SenderThread senderThread = new SenderThread(datagramSocket, sendingQueue); + senderThread.start(); + InputThread inputThread = new InputThread(senderThread, receiverThread, sendingQueue); + inputThread.start(); + + try { + receiverThread.join(); + senderThread.join(); + inputThread.join(); + } catch (InterruptedException e) { + e.printStackTrace(); + } + + datagramSocket.close(); + } catch (SocketException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + } +} \ No newline at end of file