tiennm99/zfoo
1
0
Fork 0
mirror of https://github.com/tiennm99/zfoo.git synced 2026-08-20 00:24:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat[virtual thread]: support virtual thread in net

Browse Source
This commit is contained in:
sun
2023-09-20 17:02:45 +08:00
parent d51e34327c
commit b47e8eab77
4 changed files with 7 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
net/src/main/java/com/zfoo/net/router/receiver/EnhanceUtils.java → net/src/main/java/com/zfoo/net/enhance/EnhanceUtils.java
+2 -3
View File
@@ -11,9 +11,8 @@
* See the License for the specific language governing permissions and limitations under the License.
*/
package com.zfoo.net.router.receiver;
package com.zfoo.net.enhance;
import com.zfoo.event.anno.Bus;
import com.zfoo.net.anno.Task;
import com.zfoo.net.session.Session;
import com.zfoo.protocol.util.StringUtils;
@@ -76,7 +75,7 @@ public abstract class EnhanceUtils {
enhanceClazz.addMethod(invokeMethod);
// 定义类实现的接口方法bus
CtMethod busMethod = new CtMethod(classPool.get(Bus.class.getCanonicalName()), "task", null, enhanceClazz);
CtMethod busMethod = new CtMethod(classPool.get(Task.class.getCanonicalName()), "task", null, enhanceClazz);
busMethod.setModifiers(Modifier.PUBLIC + Modifier.FINAL);
String busMethodBody = StringUtils.format("{ return {}.{}; }", Task.class.getCanonicalName(), definition.getTask());
busMethod.setBody(busMethodBody);
net/src/main/java/com/zfoo/net/router/receiver/IPacketReceiver.java → net/src/main/java/com/zfoo/net/enhance/IPacketReceiver.java
+1 -1
View File
@@ -11,7 +11,7 @@
* See the License for the specific language governing permissions and limitations under the License.
*/
package com.zfoo.net.router.receiver;
package com.zfoo.net.enhance;
import com.zfoo.net.anno.Task;
import com.zfoo.net.session.Session;
net/src/main/java/com/zfoo/net/router/receiver/PacketReceiverDefinition.java → net/src/main/java/com/zfoo/net/enhance/PacketReceiverDefinition.java
+1 -1
View File
@@ -11,7 +11,7 @@
* See the License for the specific language governing permissions and limitations under the License.
*/
package com.zfoo.net.router.receiver;
package com.zfoo.net.enhance;
import com.zfoo.net.anno.Task;
import com.zfoo.net.session.Session;
net/src/main/java/com/zfoo/net/router/Router.java
+3 -3
View File
@@ -33,9 +33,9 @@ import com.zfoo.net.router.attachment.SignalAttachment;
import com.zfoo.net.router.exception.ErrorResponseException;
import com.zfoo.net.router.exception.NetTimeOutException;
import com.zfoo.net.router.exception.UnexpectedProtocolException;
import com.zfoo.net.router.receiver.EnhanceUtils;
import com.zfoo.net.router.receiver.IPacketReceiver;
import com.zfoo.net.router.receiver.PacketReceiverDefinition;
import com.zfoo.net.enhance.EnhanceUtils;
import com.zfoo.net.enhance.IPacketReceiver;
import com.zfoo.net.enhance.PacketReceiverDefinition;
import com.zfoo.net.session.Session;
import com.zfoo.net.task.PacketReceiverTask;
import com.zfoo.net.task.TaskBus;