Method main

ZezeJava/ZezeJava/src/main/java/Zeze/Services/Token.java:844–894

(@NotNull String @NotNull [] args)

	}

	public static void main(@NotNull String @NotNull [] args) throws Exception {
		Thread.setDefaultUncaughtExceptionHandler((t, e) -> {
			//noinspection CallToPrintStackTrace
			e.printStackTrace();
			logger.error("uncaught exception in {}:", t, e);
		});

		String host = null;
		int port = 0;
		int netThreadCount = 0;
		int workerThreadCount = 0;

		for (int i = 0; i < args.length; ++i) {
			switch (args[i]) {
			case "-host":
				host = args[++i];
				if (host.isBlank())
					host = null;
				break;
			case "-port":
				port = Integer.parseInt(args[++i]);
				break;
			case "-net-threads":
				netThreadCount = Integer.parseInt(args[++i]);
				break;
			case "-worker-threads":
				workerThreadCount = Integer.parseInt(args[++i]);
				break;
			default:
				throw new IllegalArgumentException("unknown argument: " + args[i]);
			}
		}

		if (netThreadCount < 1)
			netThreadCount = Runtime.getRuntime().availableProcessors();
		if (workerThreadCount < 1)
			workerThreadCount = Runtime.getRuntime().availableProcessors() * 2;
		Task.initThreadPool(Task.newFixedThreadPool(workerThreadCount, "ZezeTaskPool"),
				Executors.newSingleThreadScheduledExecutor(
						new ThreadFactoryWithName("ZezeScheduledPool", Thread.NORM_PRIORITY + 2)));
		if (Selectors.getInstance().getCount() < netThreadCount)
			Selectors.getInstance().add(netThreadCount - Selectors.getInstance().getCount());

		var token = new Token();
		ShutdownHook.add(token::stop);

		token.start(null, host, port);
		synchronized (Thread.currentThread()) {
			Thread.currentThread().wait();
		}
	}
}