add milestone5 class

Author: wsw-stack

src/main/java/org/json/XML.java

@@ -10,6 +10,8 @@
 import java.math.BigInteger;
 import java.util.*;
 import java.io.BufferedReader;
+import java.util.concurrent.*;
+import java.util.function.Consumer;
 import java.util.function.Function;
 import java.util.stream.Collectors;
 
@@ -2237,4 +2239,158 @@ private static final String indent(int indent) {
         }
         return sb.toString();
     }
+
+//    public static class asyncRunner {
+//        private List<Future<JSONObject>> tasks;
+//        private boolean running;
+//
+//        public asyncRunner() {
+//            this.tasks = new ArrayList<>();
+//            running = false;
+//        }
+//
+//        public void add(Future<JSONObject> task) {
+//            this.tasks.add(task);
+//        }
+//
+//
+//        public void run() {
+//            running = true;
+//            while(running) {
+//                List<Future<JSONObject>> nextTasks = new ArrayList<>();
+//                for(Future<JSONObject> task: tasks) {
+//                    if(!task.isDone()) {
+//                        nextTasks.add(task);
+//                    }
+//                }
+//                running = !nextTasks.isEmpty();
+//                tasks = nextTasks;
+//            }
+//        }
+//    }
+//
+//    public static Future<JSONObject> toJSONObject(Reader reader, Consumer<JSONObject> after, Consumer<Exception> error){
+//
+//        ExecutorService executor = Executors.newSingleThreadExecutor();
+//        futureTask task = new futureTask(reader, after, error);
+//        Future<JSONObject> future = executor.submit(task);
+//
+//        return future;
+//    }
+//
+//    private static class futureTask implements Callable<JSONObject> {
+//
+//        Reader reader;
+//        Consumer<JSONObject> after;
+//        Consumer<Exception> error;
+//        public futureTask(Reader reader, Consumer<JSONObject> after, Consumer<Exception> error) {
+//            this.reader = reader;
+//            this.after = after;
+//            this.error = error;
+//        }
+//
+//        @Override
+//        public JSONObject call() throws Exception {
+//            JSONObject jo = new JSONObject();
+//            try {
+//                XMLTokener x = new XMLTokener(reader);
+//                while (x.more()) {
+//                    x.skipPast("<");
+//                    if (x.more()) {
+//                        parse(x, jo, null, XMLParserConfiguration.ORIGINAL, 0);
+//                    }
+//                }
+//                after.accept(jo);
+//            } catch (Exception e) {
+//                error.accept(e);
+//            }
+//            return jo;
+//        }
+//    }
+private static final ExecutorService executor = Executors.newFixedThreadPool(
+        Runtime.getRuntime().availableProcessors()
+);
+
+    public static Future<JSONObject> toJSONObject(
+            Reader reader,
+            Consumer<JSONObject> after,
+            Consumer<Exception> error
+    ) {
+        FutureTask<JSONObject> task = new FutureTask<>(new FutureTaskCallable(reader, after, error));
+        executor.execute(task);
+        return task;
+    }
+
+    public static void shutdownExecutor() {
+        executor.shutdown();
+    }
+
+    private static class FutureTaskCallable implements Callable<JSONObject> {
+        private final Reader reader;
+        private final Consumer<JSONObject> after;
+        private final Consumer<Exception> error;
+
+        public FutureTaskCallable(
+                Reader reader,
+                Consumer<JSONObject> after,
+                Consumer<Exception> error
+        ) {
+            this.reader = reader;
+            this.after = after;
+            this.error = error;
+        }
+
+        @Override
+        public JSONObject call() throws Exception {
+            JSONObject jo = new JSONObject();
+            try {
+                XMLTokener x = new XMLTokener(reader);
+                while (x.more()) {
+                    x.skipPast("<");
+                    if (x.more()) {
+                        parse(x, jo, null, XMLParserConfiguration.ORIGINAL, 0);
+                    }
+                }
+                after.accept(jo);
+                return jo;
+            } catch (Exception e) {
+                error.accept(e);
+                throw e;
+            }
+        }
+    }
+
+    public static class AsyncRunner {
+        private List<Future<JSONObject>> tasks = new ArrayList<>();
+
+        public AsyncRunner() {
+        }
+
+        public void add(Future<JSONObject> task) {
+            this.tasks.add(task);
+        }
+
+        public void run() {
+            boolean running = true;
+            while (running) {
+                List<Future<JSONObject>> nextTasks = new ArrayList<>();
+                for (Future<JSONObject> task : tasks) {
+                    if (!task.isDone()) {
+                        nextTasks.add(task);
+                    }
+                }
+                if (nextTasks.isEmpty()) {
+                    running = false;
+                } else {
+                    tasks = nextTasks;
+                    try {
+                        Thread.sleep(50);
+                    } catch (InterruptedException ie) {
+                        Thread.currentThread().interrupt();
+                        running = false;
+                    }
+                }
+            }
+        }
+    }
 }