Rosetta/rosetta-wss
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Улучшена типизация пакетов

Browse Source
This commit is contained in:
RoyceDa
2026-02-04 06:00:22 +02:00
parent 10f257297d
commit 6a5c01bf25
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/io/orprotocol/lock/ThreadLocker.java
View File

@@ -6,7 +6,6 @@ import java.util.concurrent.ConcurrentHashMap;
import io.orprotocol.client.Client; import io.orprotocol.client.Client;
import io.orprotocol.packet.Packet; import io.orprotocol.packet.Packet;
import io.orprotocol.packet.PacketExecutor;
/** /**
* Менеджер блокировок для обработки пакетов с аннотацией @Lock. * Менеджер блокировок для обработки пакетов с аннотацией @Lock.
@@ -21,7 +20,7 @@ public class ThreadLocker {
* @param exectuor Класс исполнителя пакета * @param exectuor Класс исполнителя пакета
* @return true, если блокировка успешно захвачена, иначе false. * @return true, если блокировка успешно захвачена, иначе false.
*/ */
public boolean acquireLock(Packet packet, Class<? extends PacketExecutor> exectuor) { public boolean acquireLock(Packet packet, Class<?> exectuor) {
try{ try{
Method prMethod = exectuor.getMethod("onPacketReceived", Packet.class, Client.class); Method prMethod = exectuor.getMethod("onPacketReceived", Packet.class, Client.class);
if(prMethod == null) { if(prMethod == null) {
@@ -58,7 +57,7 @@ public class ThreadLocker {
* @param packet Пакет для которого требуется разблокировка * @param packet Пакет для которого требуется разблокировка
* @param exectuor Класс исполнителя пакета * @param exectuor Класс исполнителя пакета
*/ */
public void releaseLock(Packet packet, Class<? extends PacketExecutor> exectuor) { public void releaseLock(Packet packet, Class<?> exectuor) {
try{ try{
Method prMethod = exectuor.getMethod("onPacketReceived", Packet.class, Client.class); Method prMethod = exectuor.getMethod("onPacketReceived", Packet.class, Client.class);
if(prMethod == null) { if(prMethod == null) {