add ProgressiveBufferedReadableCharStream + Decoder + UTF8Decoder + few performance improvements

Author: lecousin

net.lecousin.core/src/main/java/net/lecousin/framework/application/libraries/artifacts/maven/MavenPOM.java

@@ -84,7 +84,7 @@ public Void run() {
 						return;
 					}
 					IO.Readable.Buffered bio = readFile.getResult();
-					AsyncWork<XMLStreamReader, Exception> startXMLReader = XMLStreamReader.start(bio, bufSize);
+					AsyncWork<XMLStreamReader, Exception> startXMLReader = XMLStreamReader.start(bio, bufSize, 3);
 					Reader read = pom.new Reader(startXMLReader, priority, fromRepository, pomFile, pomLoader);
 					read.startOn(startXMLReader, true);
 					read.getOutput().listenInline(() -> {

net.lecousin.core/src/main/java/net/lecousin/framework/application/libraries/artifacts/maven/MavenRemoteRepository.java

@@ -81,7 +81,7 @@ public AsyncWork<List<String>, NoException> getAvailableVersions(String groupId,
 			bio = (IO.Readable.Buffered)io;
 		else
 			bio = new SimpleBufferedReadable(io, 8192);
-		AsyncWork<XMLStreamReader, Exception> start = XMLStreamReader.start(bio, 5000);
+		AsyncWork<XMLStreamReader, Exception> start = XMLStreamReader.start(bio, 5000, 4);
 		AsyncWork<List<String>, NoException> result = new AsyncWork<>();
 		start.listenAsync(new Task.Cpu.FromRunnable("Read maven-metadata.xml", priority, () -> {
 			if (!start.isSuccessful()) {

net.lecousin.core/src/main/java/net/lecousin/framework/concurrent/StandaloneTaskPriorityManager.java

@@ -22,30 +22,36 @@ public StandaloneTaskPriorityManager() {
 	private TaskManager taskManager;
 
 	@Override
-	public void setTaskManager(TaskManager taskManager) {
+	public final void setTaskManager(TaskManager taskManager) {
 		this.taskManager = taskManager;
 	}
 
 	@Override
-	public void add(Task<?, ?> task) {
-		synchronized (this) {
-			ready[task.priority].addLast(task);
-			if (nextPriority > task.priority) nextPriority = task.priority;
-			this.notify();
-		}
+	public final synchronized void add(Task<?, ?> task) {
+		ready[task.priority].addLast(task);
+		if (nextPriority > task.priority) nextPriority = task.priority;
+		this.notify();
 	}
 
 	@Override
-	public boolean remove(Task<?, ?> task) {
-		synchronized (this) {
-			return ready[task.priority].removeInstance(task);
-		}
+	public final synchronized boolean remove(Task<?, ?> task) {
+		return ready[task.priority].removeInstance(task);
 	}
 
 	@Override
-	public Task<?, ?> peekNextOrWait() {
+	public final Task<?, ?> peekNextOrWait() {
 		Task<?,?> t;
 		do {
+			if (nextPriority < Task.PRIORITY_BACKGROUND) {
+				t = ready[nextPriority].pollFirst();
+				if (t == null) {
+					nextPriority++;
+					continue;
+				}
+				if (nextPriority < Task.PRIORITY_BACKGROUND && t.executeEvery <= 0)
+					lastIdle = -1;
+				break;
+			}
 			if (nextPriority == Task.NB_PRIORITES) {
 				if (lastIdle < 0)
 					lastIdle = System.currentTimeMillis();
@@ -66,21 +72,19 @@ public boolean remove(Task<?, ?> task) {
 					}
 					return null;
 				}
+				t = ready[Task.PRIORITY_BACKGROUND].pollFirst();
+				if (t == null) {
+					nextPriority++;
+					continue;
+				}
+				break;
 			}
-			t = ready[nextPriority].pollFirst();
-			if (t == null) {
-				nextPriority++;
-				continue;
-			}
-			if (nextPriority < Task.PRIORITY_BACKGROUND && t.executeEvery <= 0)
-				lastIdle = -1;
-			break;
 		} while (true);
 		return t;
 	}
 
 	@Override
-	public Task<?, ?> peekNext() {
+	public final Task<?, ?> peekNext() {
 		Task<?,?> t;
 		do {
 			if (nextPriority == Task.NB_PRIORITES) {
@@ -101,7 +105,7 @@ public boolean remove(Task<?, ?> task) {
 	}
 
 	@Override
-	public List<Task<?, ?>> removeAllPendingTasks() {
+	public final List<Task<?, ?>> removeAllPendingTasks() {
 		LinkedList<Task<?,?>> list = new LinkedList<>();
 		for (byte p = 0; p < Task.NB_PRIORITES; ++p) {
 			while (!ready[p].isEmpty())
@@ -111,7 +115,7 @@ public boolean remove(Task<?, ?> task) {
 	}
 
 	@Override
-	public void forceStop() {
+	public final void forceStop() {
 		nextPriority = Task.NB_PRIORITES;
 		synchronized (ready) {
 			ready.notifyAll();
@@ -126,7 +130,7 @@ public void forceStop() {
 	}
 
 	@Override
-	public int getRemainingTasks(boolean includingBackground) {
+	public final int getRemainingTasks(boolean includingBackground) {
 		int nb = 0;
 		synchronized (this) {
 			for (byte p = 0; p < Task.NB_PRIORITES; ++p) if (includingBackground || p != Task.PRIORITY_BACKGROUND) nb += ready[p].size();
@@ -135,7 +139,7 @@ public int getRemainingTasks(boolean includingBackground) {
 	}
 
 	@Override
-	public boolean hasRemainingTasks(boolean includingBackground) {
+	public final boolean hasRemainingTasks(boolean includingBackground) {
 		synchronized (this) {
 			for (byte p = 0; p < Task.NB_PRIORITES; ++p)
 				if (includingBackground || p != Task.PRIORITY_BACKGROUND)