RepoMirrors
/
baritone
mirror of https://github.com/cabaletta/baritone
1
0
Fork 1
Code Issues Releases Wiki Activity

Use separate executor for solver

This commit is contained in:
Brady 2023-06-29 23:35:12 -05:00
parent b4578931d3
commit 4590ba3ff8
No known key found for this signature in database
GPG Key ID: 73A788379A197567
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/baritone/behavior/ElytraBehavior.java
View File

@ -51,9 +51,7 @@ import net.minecraft.util.math.*;
import net.minecraft.world.chunk.Chunk;
import java.util.*;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.Future;
import java.util.concurrent.*;
import java.util.function.UnaryOperator;
public final class ElytraBehavior extends Behavior implements IElytraBehavior, Helper {
@ -92,13 +90,15 @@ public final class ElytraBehavior extends Behavior implements IElytraBehavior, H
*/
private int minimumBoostTicks;
private boolean deployedFireworkLastTick;
private final int[] nextTickBoostCounter;
private BlockStateInterface bsi;
private BlockPos destination;
private final ExecutorService solverExecutor;
private Future<Solution> solver;
private Solution pendingSolution;
private boolean deployedFireworkLastTick;
private final int[] nextTickBoostCounter;
private boolean solveNextTick;
public ElytraBehavior(Baritone baritone) {
@ -109,6 +109,7 @@ public final class ElytraBehavior extends Behavior implements IElytraBehavior, H
this.visiblePath = Collections.emptyList();
this.pathManager = this.new PathManager();
this.process = new ElytraProcess();
this.solverExecutor = Executors.newSingleThreadExecutor();
this.nextTickBoostCounter = new int[2];
}
@ -524,7 +525,7 @@ public final class ElytraBehavior extends Behavior implements IElytraBehavior, H
this.pathManager.updatePlayerNear();
final SolverContext context = this.new SolverContext(true);
this.solver = CompletableFuture.supplyAsync(() -> this.solveAngles(context));
this.solver = this.solverExecutor.submit(() -> this.solveAngles(context));
this.solveNextTick = false;
}
}