Bug with use-virtual-thread-for-async-sheduler

[sh2kcs]

Checklist

• I have searched the existing issues
• I ticked all the boxes without actually reading them
• I am using latest Leaf build from https://github.com/Winds-Studio/Leaf/releases
• I tested and couldn't replicate this issue on latest Purpur build

What behaviour is observed?

Spam messages from plugin

Expected behaviour

Send 1 message to chat

To Reproduce

1. Write your own plugin and use the Bukkit#runTaskAsynchronously chat method in it
2. Use the command and you will see spam in the chat

Spark profiler link

https://spark.lucko.me/C8fKJoDG9U

Error log (if applicable)

No response

[NoltoxGit]

Hello @sh2kcs,
Your Spark profile link doesn't work. Please try sending a new one!

[Dreeam-qwq]

Can't replicate

@Override
    public void execute(CommandSender sender, String[] args, Plugin plugin) {
        if (args.length > 0) {
            switch (args[0]) {
                case "test": {
                    Bukkit.getScheduler().runTaskAsynchronously(plugin, () -> {
                        sender.sendMessage("test first message");
                    });
                    break;
                }
            }
        } else {
            sendErrorMessage();
        }

spark: https://spark.lucko.me/v67v4T5ASD

Can you provide your code for replication? and also spark profiler.

[sh2kcs]

Can't replicate

@Override
    public void execute(CommandSender sender, String[] args, Plugin plugin) {
        if (args.length > 0) {
            switch (args[0]) {
                case "test": {
                    Bukkit.getScheduler().runTaskAsynchronously(plugin, () -> {
                        sender.sendMessage("test first message");
                    });
                    break;
                }
            }
        } else {
            sendErrorMessage();
        }

spark: https://spark.lucko.me/v67v4T5ASD

Can you provide your code for replication? and also spark profiler.

if (!module.getRequestSet().contains(player) && !module.getApprovedSet().contains(player)) {
                player.sendMessage(MiniMessage.miniMessage().deserialize("<yellow>⚠ <reset><white>Отправка запроса..."));
                new BukkitRunnable() {
                    @Override
                    public void run() {
                        if (!module.getWaitingSet().contains(player)) {
                            module.getWaitingSet().add(player);
                            module.getRequestSet().add(player);
                            player.sendMessage(MiniMessage.miniMessage().deserialize("<yellow>⚠ <reset><white>Запрос на получение информации об IP-адресе был отправлен Руководству"));
                            player.sendMessage(MiniMessage.miniMessage().deserialize("<white>После его одобрения, используйте <yellow>/ip-check <white>ещё раз"));

                            Bukkit.getOnlinePlayers().forEach(pl -> {
                                if (pl.hasPermission("ssc.admin")) {
                                    player.sendMessage(MiniMessage.miniMessage().deserialize("<yellow>⚠ <reset><white>Запрос на получение информации об IP-адресе от игрока <yellow>" + player.getName()));
                                    player.sendMessage(MiniMessage.miniMessage().deserialize("<white>Чтобы принять запрос, используйте <yellow>/approve " + player.getName()));
                                    player.sendMessage(MiniMessage.miniMessage().deserialize("<white>Чтобы отклонить запрос, просто игнорируйте его"));
                                }
                            });
                        }
                    }
                }.runTaskLaterAsynchronously(LoggerModule.getInstance(), 30L);

try this pls

[Dreeam-qwq]

Still can't (

@Override
    public void execute(CommandSender sender, String[] args, Plugin plugin) {
        if (args.length > 0) {
            switch (args[0]) {
                 case "test": {
                    new BukkitRunnable() {
                        @Override
                        public void run() {
                            sender.sendMessage("Message 1");

                            Bukkit.getOnlinePlayers().forEach($ -> {
                                sender.sendMessage("Message 2");
                            });
                        }
                    }.runTaskLaterAsynchronously(plugin, 30L);

                    break;
                }
           }
        } else {
            sendErrorMessage();
        }

[sh2kcs]

Still can't (

@Override
    public void execute(CommandSender sender, String[] args, Plugin plugin) {
        if (args.length > 0) {
            switch (args[0]) {
                 case "test": {
                    new BukkitRunnable() {
                        @Override
                        public void run() {
                            sender.sendMessage("Message 1");

                            Bukkit.getOnlinePlayers().forEach($ -> {
                                sender.sendMessage("Message 2");
                            });
                        }
                    }.runTaskLaterAsynchronously(plugin, 30L);

                    break;
                }
           }
        } else {
            sendErrorMessage();
        }

Perhaps this only occurs when there is a lot of online activity.
But please try this piece of code too:

@EventHandler
    private void handle(PlayerInteractEntityEvent event){
        Entity rightClicked = event.getRightClicked();
        Bukkit.getScheduler().runTaskAsynchronously(plugin, () -> {
            Bukkit.getOnlinePlayers().forEach(player -> {
                player.sendMessage("Entity:" + rightClicked.getType().name());
            });
        });
    }