diff --git a/src/main/java/queues/src/ReceivingQueue.java b/src/main/java/queues/src/ReceivingQueue.java new file mode 100644 index 0000000..6987cc3 --- /dev/null +++ b/src/main/java/queues/src/ReceivingQueue.java @@ -0,0 +1,20 @@ +/** + * @author Aaron Moser + * @date 26.12.2023 + */ +package queues.src; + +import java.util.concurrent.LinkedBlockingQueue; + +public class ReceivingQueue extends LinkedBlockingQueue { + private static ReceivingQueue instance; + + private ReceivingQueue() {} + + public static ReceivingQueue getInstance() { + if (instance == null) { + instance = new ReceivingQueue(); + } + return instance; + } +} diff --git a/src/main/java/queues/src/SendingQueue.java b/src/main/java/queues/src/SendingQueue.java new file mode 100644 index 0000000..fe5d287 --- /dev/null +++ b/src/main/java/queues/src/SendingQueue.java @@ -0,0 +1,20 @@ +/** + * @author Aaron Moser + * @date 26.12.2023 + */ +package queues.src; + +import java.util.concurrent.LinkedBlockingQueue; + +public class SendingQueue extends LinkedBlockingQueue { + private static SendingQueue instance; + + private SendingQueue() {} + + public static SendingQueue getInstance() { + if (instance == null) { + instance = new SendingQueue(); + } + return instance; + } +}