Minecraft/mc-server
Archived
0
Fork 0
Code Releases Activity

Event loop module restructured

Browse Source
This commit is contained in:
Daniil
2018-08-03 21:18:34 +07:00
parent 8f912f7e40
commit 932682b6e1
15 changed files with 32 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
event-loop/src/main/java/mc/core/events/v3/EventPipeline.java → event-loop/src/main/java/mc/core/events/EventPipeline.java
View File

@@ -1,12 +1,12 @@
package mc.core.events.v3;
package mc.core.events;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import lombok.Setter;
import lombok.extern.slf4j.Slf4j;
import mc.core.events.Event;
import mc.core.events.v3.runner.EventExecutorService;
import mc.core.events.v3.runner.ResourceRunnable;
import mc.core.events.api.EventQueueOwner;
import mc.core.events.runner.EventExecutorService;
import mc.core.events.runner.ResourceRunnable;
import java.lang.reflect.InvocationTargetException;
import java.util.List;

9
event-loop/src/main/java/mc/core/events/v3/FullAsyncEventLoop.java → event-loop/src/main/java/mc/core/events/FullAsyncEventLoop.java
View File

@@ -1,10 +1,11 @@
package mc.core.events.v3;
package mc.core.events;
import lombok.Setter;
import lombok.extern.slf4j.Slf4j;
import mc.core.events.Event;
import mc.core.events.EventHandler;
import mc.core.events.v3.runner.EventExecutorService;
import mc.core.events.api.EventHandler;
import mc.core.events.api.EventQueueOwner;
import mc.core.events.api.Plugin;
import mc.core.events.runner.EventExecutorService;
import org.springframework.beans.factory.annotation.Autowired;
import java.lang.reflect.Method;

5
event-loop/src/main/java/mc/core/events/v3/RegisteredEventHandler.java → event-loop/src/main/java/mc/core/events/RegisteredEventHandler.java
View File

@@ -1,8 +1,9 @@
package mc.core.events.v3;
package mc.core.events;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import mc.core.events.LockableResource;
import mc.core.events.api.LockableResource;
import mc.core.events.api.Plugin;
import java.lang.reflect.Method;

2
event-loop/src/main/java/mc/core/events/EventHandler.java → event-loop/src/main/java/mc/core/events/api/EventHandler.java
View File

@@ -1,4 +1,4 @@
package mc.core.events;
package mc.core.events.api;
import java.lang.annotation.*;

2
event-loop/src/main/java/mc/core/events/EventPriority.java → event-loop/src/main/java/mc/core/events/api/EventPriority.java
View File

@@ -1,4 +1,4 @@
package mc.core.events;
package mc.core.events.api;
import lombok.Getter;

2
event-loop/src/main/java/mc/core/events/v3/EventQueueOwner.java → event-loop/src/main/java/mc/core/events/api/EventQueueOwner.java
View File

@@ -1,4 +1,4 @@
package mc.core.events.v3;
package mc.core.events.api;
public interface EventQueueOwner {
}

2
event-loop/src/main/java/mc/core/events/LockableResource.java → event-loop/src/main/java/mc/core/events/api/LockableResource.java
View File

@@ -1,4 +1,4 @@
package mc.core.events;
package mc.core.events.api;
public enum LockableResource {
PLAYER,

2
event-loop/src/main/java/mc/core/events/v3/Plugin.java → event-loop/src/main/java/mc/core/events/api/Plugin.java
View File

@@ -1,4 +1,4 @@
package mc.core.events.v3;
package mc.core.events.api;
public interface Plugin {
}

4
event-loop/src/main/java/mc/core/events/v3/lock/CustomReentrantLock.java → event-loop/src/main/java/mc/core/events/lock/CustomReentrantLock.java
View File

@@ -1,6 +1,6 @@
package mc.core.events.v3.lock;
package mc.core.events.lock;
import mc.core.events.v3.runner.ExecutorThread;
import mc.core.events.runner.ExecutorThread;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.ReentrantLock;

2
event-loop/src/main/java/mc/core/events/v3/runner/EventExecutorService.java → event-loop/src/main/java/mc/core/events/runner/EventExecutorService.java
View File

@@ -1,4 +1,4 @@
package mc.core.events.v3.runner;
package mc.core.events.runner;
import sun.plugin.dom.exception.InvalidStateException;

2
event-loop/src/main/java/mc/core/events/v3/runner/ExecutorThread.java → event-loop/src/main/java/mc/core/events/runner/ExecutorThread.java
View File

@@ -1,4 +1,4 @@
package mc.core.events.v3.runner;
package mc.core.events.runner;
public class ExecutorThread extends Thread {
private EventExecutorService service;

2
event-loop/src/main/java/mc/core/events/v3/runner/ResourceRunnable.java → event-loop/src/main/java/mc/core/events/runner/ResourceRunnable.java
View File

@@ -1,4 +1,4 @@
package mc.core.events.v3.runner;
package mc.core.events.runner;
public interface ResourceRunnable extends Runnable {
default void lock() {

2
event-loop/src/main/java/mc/core/events/v3/runner/ScheduleStrategy.java → event-loop/src/main/java/mc/core/events/runner/ScheduleStrategy.java
View File

@@ -1,4 +1,4 @@
package mc.core.events.v3.runner;
package mc.core.events.runner;
public interface ScheduleStrategy {
ResourceRunnable getTask() throws InterruptedException;

6
event-loop/src/test/java/ru/core/events/v3/EventExecutorTest.java → event-loop/src/test/java/mc/core/events/EventExecutorTest.java
View File

@@ -1,7 +1,7 @@
package ru.core.events.v3;
package mc.core.events;
import mc.core.events.v3.runner.EventExecutorService;
import mc.core.events.v3.runner.ResourceRunnable;
import mc.core.events.runner.EventExecutorService;
import mc.core.events.runner.ResourceRunnable;
import org.junit.Assert;
import org.junit.Test;

14
event-loop/src/test/java/ru/core/events/v3/EventLoopTest.java → event-loop/src/test/java/mc/core/events/EventLoopTest.java
View File

@@ -1,12 +1,10 @@
package ru.core.events.v3;
package mc.core.events;
import mc.core.events.EventHandler;
import mc.core.events.EventPriority;
import mc.core.events.LoginEvent;
import mc.core.events.v3.EventQueueOwner;
import mc.core.events.v3.FullAsyncEventLoop;
import mc.core.events.v3.Plugin;
import mc.core.events.v3.runner.EventExecutorService;
import mc.core.events.api.EventHandler;
import mc.core.events.api.EventPriority;
import mc.core.events.api.EventQueueOwner;
import mc.core.events.api.Plugin;
import mc.core.events.runner.EventExecutorService;
import org.junit.Assert;
import org.junit.Test;