Mirror von
https://github.com/IntellectualSites/FastAsyncWorldEdit.git
synchronisiert 2024-11-20 18:00:09 +01:00
add getter and setter for task
Dieser Commit ist enthalten in:
Ursprung
5969d99db1
Commit
80c9614c15
@ -17,6 +17,8 @@ import com.sk89q.worldedit.world.block.BaseBlock;
|
|||||||
import com.sk89q.worldedit.world.block.BlockState;
|
import com.sk89q.worldedit.world.block.BlockState;
|
||||||
import org.jetbrains.annotations.Nullable;
|
import org.jetbrains.annotations.Nullable;
|
||||||
|
|
||||||
|
import javax.annotation.Nonnull;
|
||||||
|
import java.util.Objects;
|
||||||
import java.util.function.Consumer;
|
import java.util.function.Consumer;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -28,7 +30,7 @@ public class OncePerChunkExtent extends AbstractDelegateExtent implements IBatch
|
|||||||
|
|
||||||
private final LocalBlockVector2Set set = new LocalBlockVector2Set();
|
private final LocalBlockVector2Set set = new LocalBlockVector2Set();
|
||||||
private final IQueueExtent<IQueueChunk> queue;
|
private final IQueueExtent<IQueueChunk> queue;
|
||||||
private final Consumer<IChunkGet> task;
|
private Consumer<IChunkGet> task;
|
||||||
private volatile long lastPair = Long.MAX_VALUE;
|
private volatile long lastPair = Long.MAX_VALUE;
|
||||||
private volatile boolean isProcessing;
|
private volatile boolean isProcessing;
|
||||||
|
|
||||||
@ -40,10 +42,14 @@ public class OncePerChunkExtent extends AbstractDelegateExtent implements IBatch
|
|||||||
* @param task Consumer task for the chunk GET
|
* @param task Consumer task for the chunk GET
|
||||||
* @since TODO
|
* @since TODO
|
||||||
*/
|
*/
|
||||||
public OncePerChunkExtent(Extent extent, IQueueExtent<IQueueChunk> queue, Consumer<IChunkGet> task) {
|
public OncePerChunkExtent(
|
||||||
|
@Nonnull Extent extent,
|
||||||
|
@Nonnull IQueueExtent<IQueueChunk> queue,
|
||||||
|
@Nonnull Consumer<IChunkGet> task
|
||||||
|
) {
|
||||||
super(extent);
|
super(extent);
|
||||||
this.queue = queue;
|
this.queue = Objects.requireNonNull(queue);
|
||||||
this.task = task;
|
this.task = Objects.requireNonNull(task);
|
||||||
}
|
}
|
||||||
|
|
||||||
private boolean shouldRun(int chunkX, int chunkZ) {
|
private boolean shouldRun(int chunkX, int chunkZ) {
|
||||||
@ -67,6 +73,14 @@ public class OncePerChunkExtent extends AbstractDelegateExtent implements IBatch
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public Consumer<IChunkGet> getTask() {
|
||||||
|
return task;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setTask(Consumer<IChunkGet> task) {
|
||||||
|
this.task = task;
|
||||||
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public IChunkSet processSet(final IChunk chunk, final IChunkGet get, final IChunkSet set) {
|
public IChunkSet processSet(final IChunk chunk, final IChunkGet get, final IChunkSet set) {
|
||||||
return set;
|
return set;
|
||||||
|
Laden…
In neuem Issue referenzieren
Einen Benutzer sperren