Quick sort with Callable implementation

os/code/os/src/main/java/com/scaler/quicksort/QuickRunner.java

@@ -0,0 +1,20 @@
+package com.scaler.quicksort;
+
+import java.util.concurrent.*;
+
+public class QuickRunner {
+
+    public static void main(String[] args) throws ExecutionException, InterruptedException {
+        Integer[] arr = {10, 9, 8, 7, 1, 2, 3, 4};
+
+        ExecutorService executor = Executors.newCachedThreadPool();
+        QuickSorter sorter = new QuickSorter(arr, executor,0,arr.length-1);
+        Future<Integer[]> future = executor.submit(sorter);
+        arr = future.get();
+        executor.shutdown();
+
+        for(int i=0; i<arr.length; i++){
+            System.out.print(arr[i]+" ");
+        }
+    }
+}

os/code/os/src/main/java/com/scaler/quicksort/QuickSorter.java

@@ -0,0 +1,48 @@
+package com.scaler.quicksort;
+
+import lombok.AllArgsConstructor;
+
+import java.util.concurrent.Callable;
+import java.util.concurrent.ExecutorService;
+
+@AllArgsConstructor
+public class QuickSorter implements Callable<Integer[]> {
+
+    private Integer[] values;
+    private ExecutorService es;
+    private int start;
+    private int end;
+
+    private int partition (Integer[] a, int start, int end)
+    {
+        int pivot = a[end]; // pivot element
+        int i = (start - 1);
+
+        for (int j = start; j <= end - 1; j++)
+        {
+            // If current element is smaller than the pivot
+            if (a[j] < pivot)
+            {
+                i++; // increment index of smaller element
+                int t = a[i];
+                a[i] = a[j];
+                a[j] = t;
+            }
+        }
+        int t = a[i+1];
+        a[i+1] = a[end];
+        a[end] = t;
+        return (i + 1);
+    }
+
+
+    @Override
+    public Integer[] call() throws Exception {
+        if(start < end) {
+            int p = partition(values, start, end);
+            es.submit(new QuickSorter(values, es, start, p - 1));
+            es.submit(new QuickSorter(values, es, p + 1, end));
+        }
+        return values;
+    }
+}