a bit cleaning + SocketUtils + TaskManager (will be more advance)

Author: RealSuperUser

pom.xml

@@ -29,7 +29,13 @@
             <artifactId>annotations</artifactId>
             <version>24.1.0</version>
         </dependency>
-    </dependencies>
+      <dependency>
+          <groupId>org.projectlombok</groupId>
+          <artifactId>lombok</artifactId>
+          <version>RELEASE</version>
+          <scope>compile</scope>
+      </dependency>
+  </dependencies>
   <build>
     <pluginManagement>
       <plugins>
@@ -71,16 +77,5 @@
         </plugin>
       </plugins>
     </pluginManagement>
-      <plugins>
-          <plugin>
-              <groupId>org.apache.maven.plugins</groupId>
-              <artifactId>maven-compiler-plugin</artifactId>
-              <configuration>
-                  <source>17</source>
-                  <target>17</target>
-                  <compilerArgs>--enable-preview</compilerArgs>
-              </configuration>
-          </plugin>
-      </plugins>
   </build>
 </project>

src/main/java/ir/xenoncommunity/Main.java

@@ -1,11 +1,12 @@
 package ir.xenoncommunity;
 
 import ir.xenoncommunity.utils.CommandLineParser;
+import lombok.Getter;
 
 public class Main {
+	public static MainRunner runner;
 	public static void main(String[] args) {
-		CommandLineParser parser = new CommandLineParser(args);
-		MainRunner runner = new MainRunner(parser);
+		Main.runner = new MainRunner(new CommandLineParser(args));
 		runner.run();
 	}
 }

src/main/java/ir/xenoncommunity/MainRunner.java

@@ -1,17 +1,24 @@
 package ir.xenoncommunity;
 
 import ir.xenoncommunity.utils.CommandLineParser;
+import ir.xenoncommunity.utils.SocketUtils;
+import ir.xenoncommunity.utils.TaskManager;
+import lombok.Getter;
+import lombok.val;
 
+@Getter
 public class MainRunner {
-	private final CommandLineParser parser;
+	public final CommandLineParser parser;
+	public final TaskManager taskManager;
+	public final SocketUtils socketUtils;
 
 	public MainRunner(CommandLineParser parser) {
 		this.parser = parser;
+		this.taskManager = new TaskManager();
+		this.socketUtils = new SocketUtils();
 	}
-
 	public void run() {
-		System.out.println(parser.get("-examplestring", String.class));
-		System.out.println(parser.get("-exampleinteger", Integer.class));
-		System.out.println(parser.get("-exampleboolean", Boolean.class));
+		val isResult = Main.runner.parser.get("--sendResult", Boolean.class);
+		val isKeepAlive = Main.runner.parser.get("--keepAlive", Boolean.class);
 	}
 }

src/main/java/ir/xenoncommunity/utils/CommandLineParser.java

@@ -13,10 +13,8 @@ public CommandLineParser(String[] args) {
 	@Nullable
 	public <T> T get(String arg, Class<T> type) {
 		for (int i = 0; i < args.length - 1; i++) {
-			if (args[i].equals(arg)) {
-				String value = args[i + 1];
-				return convertToType(value, type);
-			}
+			if (args[i].equals(arg))
+				return convertToType(args[i + 1], type);
 		}
 		return null;
 	}

src/main/java/ir/xenoncommunity/utils/SocketUtils.java

@@ -0,0 +1,26 @@
+package ir.xenoncommunity.utils;
+
+import ir.xenoncommunity.Main;
+import ir.xenoncommunity.MainRunner;
+import lombok.SneakyThrows;
+import lombok.experimental.UtilityClass;
+import lombok.val;
+
+import java.net.InetSocketAddress;
+import java.net.Socket;
+import java.net.SocketAddress;
+
+public class SocketUtils {
+   
+    @SneakyThrows
+    public void connect(final String ipIn, final int port, final boolean sendResult, final boolean keepAlive){
+        val socket = new Socket(ipIn, port);
+        if(sendResult && socket.isConnected()) System.out.println(String.format("Connected! ip: %s, port: %s, threads: %s", ipIn, port, Main.runner.getTaskManager().tasks.size()));
+        if(keepAlive) {
+            socket.setKeepAlive(true);
+        } else{
+            socket.close();
+        }
+
+    }
+}

src/main/java/ir/xenoncommunity/utils/TaskManager.java

@@ -0,0 +1,22 @@
+package ir.xenoncommunity.utils;
+
+import lombok.experimental.UtilityClass;
+import lombok.val;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class TaskManager {
+    public List<Thread> tasks = new ArrayList<>();
+    public void add(final Thread threadIn){
+        tasks.add(threadIn);
+    }
+    public void remove(final int idIn){
+        tasks.get(idIn).interrupt();
+    }
+    public void doTasks(){
+        tasks.forEach(e ->{
+            e.start();
+        });
+    }
+}