From a6423b641141b7d5a55b8b0666038e8567a559d6 Mon Sep 17 00:00:00 2001 From: Hardik Pawar Date: Mon, 14 Oct 2024 18:45:34 +0530 Subject: [PATCH 1/2] feat: Add `SelfAdjustingScheduling` new algorithm with Junit tests --- .../scheduling/SelfAdjustingScheduling.java | 63 +++++++++++++++++++ .../SelfAdjustingSchedulingTest.java | 57 +++++++++++++++++ 2 files changed, 120 insertions(+) create mode 100644 src/main/java/com/thealgorithms/scheduling/SelfAdjustingScheduling.java create mode 100644 src/test/java/com/thealgorithms/scheduling/SelfAdjustingSchedulingTest.java diff --git a/src/main/java/com/thealgorithms/scheduling/SelfAdjustingScheduling.java b/src/main/java/com/thealgorithms/scheduling/SelfAdjustingScheduling.java new file mode 100644 index 000000000000..15159a07d2d4 --- /dev/null +++ b/src/main/java/com/thealgorithms/scheduling/SelfAdjustingScheduling.java @@ -0,0 +1,63 @@ +package com.thealgorithms.scheduling; + +import java.util.PriorityQueue; + +/** + * SelfAdjustingScheduling is an algorithm where tasks dynamically adjust + * their priority based on real-time feedback, such as wait time and CPU usage. + * Tasks that wait longer will automatically increase their priority, + * allowing for better responsiveness and fairness in task handling. + * + * Use Case: Real-time systems that require dynamic prioritization + * of tasks to maintain system responsiveness and fairness. + * + * @author Hardvan + */ +public final class SelfAdjustingScheduling { + + private static class Task implements Comparable { + String name; + int waitTime; + int priority; + + Task(String name, int priority) { + this.name = name; + this.waitTime = 0; + this.priority = priority; + } + + void incrementWaitTime() { + waitTime++; + priority = priority + waitTime; + } + + @Override + public int compareTo(Task other) { + return Integer.compare(this.priority, other.priority); + } + } + + private final PriorityQueue taskQueue; + + public SelfAdjustingScheduling() { + taskQueue = new PriorityQueue<>(); + } + + public void addTask(String name, int priority) { + taskQueue.offer(new Task(name, priority)); + } + + public String scheduleNext() { + if (taskQueue.isEmpty()) { + return null; + } + Task nextTask = taskQueue.poll(); + nextTask.incrementWaitTime(); + taskQueue.offer(nextTask); + return nextTask.name; + } + + public boolean isEmpty() { + return taskQueue.isEmpty(); + } +} diff --git a/src/test/java/com/thealgorithms/scheduling/SelfAdjustingSchedulingTest.java b/src/test/java/com/thealgorithms/scheduling/SelfAdjustingSchedulingTest.java new file mode 100644 index 000000000000..8675a1ec397d --- /dev/null +++ b/src/test/java/com/thealgorithms/scheduling/SelfAdjustingSchedulingTest.java @@ -0,0 +1,57 @@ +package com.thealgorithms.scheduling; + +import static org.junit.jupiter.api.Assertions.assertEquals; +import static org.junit.jupiter.api.Assertions.assertNull; + +import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Test; + +public class SelfAdjustingSchedulingTest { + + private SelfAdjustingScheduling scheduler; + + @BeforeEach + public void setup() { + scheduler = new SelfAdjustingScheduling(); + } + + @Test + public void testAddAndScheduleSingleTask() { + scheduler.addTask("Task1", 5); + assertEquals("Task1", scheduler.scheduleNext()); + } + + @Test + public void testAddMultipleTasks() { + scheduler.addTask("Task1", 5); + scheduler.addTask("Task2", 1); + scheduler.addTask("Task3", 3); + assertEquals("Task2", scheduler.scheduleNext()); + assertEquals("Task2", scheduler.scheduleNext()); + assertEquals("Task3", scheduler.scheduleNext()); + } + + @Test + public void testPriorityAdjustment() { + scheduler.addTask("Task1", 1); + scheduler.addTask("Task2", 1); + scheduler.scheduleNext(); + scheduler.scheduleNext(); + scheduler.scheduleNext(); + assertEquals("Task2", scheduler.scheduleNext()); + } + + @Test + public void testEmptyScheduler() { + assertNull(scheduler.scheduleNext()); + } + + @Test + public void testTaskReschedulingAfterWait() { + scheduler.addTask("Task1", 1); + scheduler.addTask("Task2", 2); + scheduler.scheduleNext(); + scheduler.scheduleNext(); + assertEquals("Task1", scheduler.scheduleNext()); + } +} From cb39b7567f94fcbae430aa5d761b46e717be66d6 Mon Sep 17 00:00:00 2001 From: Hardvan Date: Mon, 14 Oct 2024 13:15:52 +0000 Subject: [PATCH 2/2] Update directory --- DIRECTORY.md | 2 ++ 1 file changed, 2 insertions(+) diff --git a/DIRECTORY.md b/DIRECTORY.md index 4c454088088b..04f06f510497 100644 --- a/DIRECTORY.md +++ b/DIRECTORY.md @@ -520,6 +520,7 @@ * [NonPreemptivePriorityScheduling](https://github.com/TheAlgorithms/Java/blob/master/src/main/java/com/thealgorithms/scheduling/NonPreemptivePriorityScheduling.java) * [PreemptivePriorityScheduling](https://github.com/TheAlgorithms/Java/blob/master/src/main/java/com/thealgorithms/scheduling/PreemptivePriorityScheduling.java) * [RRScheduling](https://github.com/TheAlgorithms/Java/blob/master/src/main/java/com/thealgorithms/scheduling/RRScheduling.java) + * [SelfAdjustingScheduling](https://github.com/TheAlgorithms/Java/blob/master/src/main/java/com/thealgorithms/scheduling/SelfAdjustingScheduling.java) * [SJFScheduling](https://github.com/TheAlgorithms/Java/blob/master/src/main/java/com/thealgorithms/scheduling/SJFScheduling.java) * [SRTFScheduling](https://github.com/TheAlgorithms/Java/blob/master/src/main/java/com/thealgorithms/scheduling/SRTFScheduling.java) * searches @@ -1071,6 +1072,7 @@ * [NonPreemptivePrioritySchedulingTest](https://github.com/TheAlgorithms/Java/blob/master/src/test/java/com/thealgorithms/scheduling/NonPreemptivePrioritySchedulingTest.java) * [PreemptivePrioritySchedulingTest](https://github.com/TheAlgorithms/Java/blob/master/src/test/java/com/thealgorithms/scheduling/PreemptivePrioritySchedulingTest.java) * [RRSchedulingTest](https://github.com/TheAlgorithms/Java/blob/master/src/test/java/com/thealgorithms/scheduling/RRSchedulingTest.java) + * [SelfAdjustingSchedulingTest](https://github.com/TheAlgorithms/Java/blob/master/src/test/java/com/thealgorithms/scheduling/SelfAdjustingSchedulingTest.java) * [SJFSchedulingTest](https://github.com/TheAlgorithms/Java/blob/master/src/test/java/com/thealgorithms/scheduling/SJFSchedulingTest.java) * [SRTFSchedulingTest](https://github.com/TheAlgorithms/Java/blob/master/src/test/java/com/thealgorithms/scheduling/SRTFSchedulingTest.java) * searches