dvorakmortonxd/FoliaFlow
1
1
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

AsyncScheduler

Browse source
This commit is contained in:
MidnightTale 2023-04-13 11:16:48 +07:00
commit 91bd89abe8
1 changed files with 22 additions and 24 deletions
Download patch file Download diff file Expand all files Collapse all files

46
src/main/java/xyz/hynse/foliaflow/FoliaFlow.java
View file

@ -1,5 +1,7 @@
package xyz.hynse.foliaflow;
import io.papermc.paper.threadedregions.scheduler.AsyncScheduler;
import io.papermc.paper.threadedregions.scheduler.ScheduledTask;
import org.bukkit.*;
import org.bukkit.block.Block;
import org.bukkit.entity.Entity;
@ -8,15 +10,10 @@ import org.bukkit.entity.FallingBlock;
import org.bukkit.event.EventHandler;
import org.bukkit.event.Listener;
import org.bukkit.event.entity.EntityChangeBlockEvent;
import org.bukkit.event.entity.EntitySpawnEvent;
import org.bukkit.event.world.ChunkEvent;
import org.bukkit.event.world.ChunkLoadEvent;
import org.bukkit.plugin.java.JavaPlugin;
import org.bukkit.util.Vector;
import java.util.HashSet;
import java.util.Set;
import java.util.stream.Collectors;
import java.util.concurrent.TimeUnit;
public class FoliaFlow extends JavaPlugin implements Listener {
private final Vector velocity1 = new Vector(0, 0.5, -1);
@ -26,12 +23,29 @@ public class FoliaFlow extends JavaPlugin implements Listener {
private final Vector[] velocities = {velocity1, velocity2, velocity3, velocity4};
private int counter = 0;
//private final Set<Location> movingBlocks = new HashSet<>();
private ScheduledTask task;
@Override
public void onEnable() {
super.onEnable();
Bukkit.getScheduler().runTaskTimer(this, this::tick, 0, 1);
AsyncScheduler scheduler = this.getServer().getAsyncScheduler();
task = scheduler.runAtFixedRate(this, (scheduledTask) -> {
for (World world : Bukkit.getWorlds()) {
for (Entity entity : world.getEntities()) {
if (entity.getType() == EntityType.FALLING_BLOCK && entity.getWorld().getEnvironment() == World.Environment.THE_END) {
Location loc = entity.getLocation();
debug("Falling block spawned at location " + loc);
// Set the initial velocity of the falling block
int index = counter % 4;
counter++;
Vector velocity = velocities[index];
entity.setVelocity(velocity);
}
}
}
}, 0L, 1L, TimeUnit.MILLISECONDS);
getServer().getPluginManager().registerEvents(this, this);
getServer().getConsoleSender().sendMessage("");
getServer().getConsoleSender().sendMessage(ChatColor.GREEN + " ______________ ");
@ -48,6 +62,7 @@ public class FoliaFlow extends JavaPlugin implements Listener {
public void onDisable() {
super.onDisable();
debug("Plugin stopped successfully!");
task.cancel();
}
/*
@ -96,23 +111,6 @@ public class FoliaFlow extends JavaPlugin implements Listener {
}
private void tick() {
for (Entity entity : Bukkit.getWorlds().stream().flatMap(world -> world.getEntities().stream())
.filter(entity -> entity.getType() == EntityType.FALLING_BLOCK && entity.getWorld().getEnvironment() == World.Environment.THE_END)
.collect(Collectors.toList())) {
Location loc = entity.getLocation();
debug("Falling block spawned at location " + loc);
// Set the initial velocity of the falling block
int index = counter % 4;
counter ++;
Vector velocity = velocities[index];
entity.setVelocity(velocity);
}
}