update to patch version v1.1.2

add perform async send methode

Author: mintUI9976

README.md

@@ -2,7 +2,7 @@
 <a href="https://zyonicsoftware.com"> <img src="https://i.postimg.cc/HnjVQNdQ/signal.png" /></a>
 <h2>A library for java with the native java socket technology and in combination with the custom bytebuffer allocator technology by boonproject</h2>
  <hr />
- <a href="https://gitlab.zyonicsoftware.com/mint9976/Signal/-/packages"><img src="https://img.shields.io/badge/release-v1.1.0-9cf" /></a>
+ <a href="https://gitlab.zyonicsoftware.com/mint9976/Signal/-/packages"><img src="https://img.shields.io/badge/release-v1.1.2-9cf" /></a>
  <a href="https://github.com/mintUI9976/Signal"><img src="https://img.shields.io/github/languages/code-size/mintUI9976/Signal?color=orange" /></a>
  <a href="https://github.com/mintUI9976/Signal"><img src="https://img.shields.io/tokei/lines/github/mintUI9976/Signal?color=yellow" /></a>
  <a href="https://github.com/mintUI9976/Signal/blob/master/LICENSE"><img src="https://img.shields.io/github/license/mintUI9976/Signal" /></a>
@@ -62,7 +62,7 @@ maven{url"https://gitlab.zyonicsoftware.com/api/v4/projects/144/packages/maven"}
 ````
 
 ````xml
-compile group:'com.zyonicsoftware.minereaper.signal',name:'Signal',version:'v1.1.0'
+compile group:'com.zyonicsoftware.minereaper.signal',name:'Signal',version:'v1.1.2'
 ````
 
 <hr />
@@ -74,12 +74,12 @@ compile group:'com.zyonicsoftware.minereaper.signal',name:'Signal',version:'v1.1
 <dependency>
  <groupId>com.zyonicsoftware.minereaper.signal</groupId>
  <artifactId>Signal</artifactId>
- <version>v1.1.0</version>
+ <version>v1.1.2</version>
 </dependency>
 ````
 
 ````xml
-mvn dependency:get -Dartifact=com.zyonicsoftware.minereaper.signal:Signal:v1.1.0
+mvn dependency:get -Dartifact=com.zyonicsoftware.minereaper.signal:Signal:v1.1.2
 ````
 
 ````xml

build.gradle

@@ -7,7 +7,7 @@ plugins {
 apply plugin: 'maven'
 
 group 'com.zyonicsoftware.minereaper.signal'
-version 'v1.1.0'
+version 'v1.1.2'
 
 tasks.withType(JavaCompile) {
  options.encoding = 'UTF-8'

src/main/java/com/zyonicsoftware/minereaper/signal/client/Client.java

@@ -11,6 +11,7 @@
 
 import com.zyonicsoftware.minereaper.enums.EugeneFactoryPriority;
 import com.zyonicsoftware.minereaper.redeugene.RedEugene;
+import com.zyonicsoftware.minereaper.scheduler.RedEugeneIntroduction;
 import com.zyonicsoftware.minereaper.signal.allocator.Allocation;
 import com.zyonicsoftware.minereaper.signal.allocator.Allocator;
 import com.zyonicsoftware.minereaper.signal.caller.SignalCallRegistry;
@@ -44,6 +45,7 @@ public class Client extends Connection {
  private long incomingPackets;
  private long outgoingPackets;
  private boolean disconnected;
+ private boolean performSendAsync;
 
  public long getIncomingPackets() {
  return this.incomingPackets;
@@ -93,13 +95,15 @@ public Client(
  final int port,
  @NotNull final Class<? extends SignalCaller> signalCaller,
  final long scheduleDelay,
+ final boolean performSendAsync,
  final int timeout) {
  this.hostname = hostname;
  this.port = port;
  RedEugeneScheduler.setRedEugene(
  new RedEugene("SignalClientPool", 3, false, EugeneFactoryPriority.NORM));
  SignalCallRegistry.registerReferenceCaller(signalCaller);
  this.scheduleDelay = scheduleDelay;
+ this.performSendAsync = performSendAsync;
  this.timeout = timeout;
  this.disconnected = false;
  Allocator.setAllocation(Allocation.CLIENT_SIDE);
@@ -126,12 +130,14 @@ public Client(
  @NotNull final Class<? extends SignalCaller> signalCaller,
  final RedEugene redEugene,
  final long scheduleDelay,
+ final boolean performSendAsync,
  final int timeout) {
  this.hostname = hostname;
  this.port = port;
  RedEugeneScheduler.setRedEugene(redEugene);
  SignalCallRegistry.registerReferenceCaller(signalCaller);
  this.scheduleDelay = scheduleDelay;
+ this.performSendAsync = performSendAsync;
  this.timeout = timeout;
  this.disconnected = false;
  Allocator.setAllocation(Allocation.CLIENT_SIDE);
@@ -241,6 +247,10 @@ public boolean isDisconnected() {
 
  /** @param packet adds the packet to list */
  public void send(final Packet packet) {
- this.outputStreamThread.send(packet);
+ if (!this.performSendAsync){
+ this.outputStreamThread.send(packet);
+ } else {
+ RedEugeneScheduler.getRedEugene().getRedThreadPool().execute(() -> outputStreamThread.send(packet));
+ }
  }
 }

src/main/java/com/zyonicsoftware/minereaper/signal/example/ExampleClient.java

@@ -50,7 +50,7 @@ private static void registerPackets() {
  */
  private static void executeClient() throws IOException {
  ExampleClient.client =
- new Client("localhost", 9976, ExampleSignalMessageInstance.class, 60, 20 * 1000);
+ new Client("localhost", 9976, ExampleSignalMessageInstance.class, 60, true,20 * 1000);
  ExampleClient.client.connect();
  System.out.println("Client has been connect on port: " + ExampleClient.client.getPort());
  }