Redstoner/CommandManager
Archived
0
Fork 0
Code Pull Requests Activity

Added support for Async commands

Browse Source
This commit is contained in:
Pepich
2017-02-01 11:55:02 +01:00
parent a6e089ed79
commit 67a6b13f64
4 changed files with 65 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
src/main/java/com/nemez/cmdmgr/util/AsyncExecutableDefinition.java Normal file
View File

@@ -0,0 +1,39 @@
package com.nemez.cmdmgr.util;
import java.lang.reflect.Method;
import java.util.ArrayList;
import org.bukkit.command.CommandSender;
import org.bukkit.plugin.java.JavaPlugin;
import com.nemez.cmdmgr.component.ICommandComponent;
public class AsyncExecutableDefinition extends ExecutableDefinition
{
public AsyncExecutableDefinition(ArrayList<ICommandComponent> cmd, ArrayList<Integer> paramLinks, String perm,
Method method, Object methodContainer, Type type)
{
super(cmd, paramLinks, perm, method, methodContainer, type);
}
@Override
public boolean invoke(Object[] args, CommandSender sender, JavaPlugin plugin)
{
Thread t = new Thread(new Runnable()
{
@Override
public void run()
{
invokeFromThread(args, sender, plugin);
}
});
t.setDaemon(true);
t.start();
return true;
}
private final void invokeFromThread(Object[] args, CommandSender sender, JavaPlugin plugin)
{
super.invoke(args, sender, plugin);
}
}

12
src/main/java/com/nemez/cmdmgr/util/Executable.java
View File

@@ -1,3 +1,4 @@
//@noformat
package com.nemez.cmdmgr.util;
import java.lang.reflect.Field;
@@ -14,6 +15,7 @@ import org.bukkit.entity.Player;
import org.bukkit.plugin.java.JavaPlugin;
import com.nemez.cmdmgr.Command;
import com.nemez.cmdmgr.Command.AsyncType;
import com.nemez.cmdmgr.CommandManager;
import com.nemez.cmdmgr.component.BooleanComponent;
import com.nemez.cmdmgr.component.ByteComponent;
@@ -263,8 +265,15 @@ public class Executable extends org.bukkit.command.Command {
if (etype == null) {
etype = Type.BOTH;
}
ExecutableDefinition def = new ExecutableDefinition(command, links, permission, target, methodContainer, etype);
ExecutableDefinition def;
AsyncType type = target.getAnnotation(Command.class).async();
if (type == AsyncType.ALWAYS)
def = new AsyncExecutableDefinition(command, links, permission, target, methodContainer, etype);
else
def = new ExecutableDefinition(command, links, permission, target, methodContainer, etype);
commands.add(def);
if (def instanceof AsyncExecutableDefinition)
CommandManager.asyncExecutables.add(this);
}
@Override
@@ -426,3 +435,4 @@ public class Executable extends org.bukkit.command.Command {
}
}
}
//@format