java socket伪异步IO式

﹏ヽ暗。殇╰゛Y 2022-01-17 08:19 180阅读 0赞

[为什么80%的码农都做不了架构师？>>> ][80_] ![hot3.png][]

import java.io.IOException;

import java.net.ServerSocket;

import java.net.Socket;

/\*\*

\* 伪异步IO模式:线程池

\* @author

\*

\*/

public class TimeServer \{

public static void main(String\[\] args) \{

int port = 8080;

if(null != args && args.length > 0) \{

try \{

port = Integer.parseInt(args\[0\]);

\} catch (NumberFormatException e) \{

e.printStackTrace();

\}

\}

ServerSocket server = null;

try \{

server = new ServerSocket(port);

System.out.println("the timeserver is start in port "+port);

Socket socket = null;

//创建IO任务线程池

TimeServerHandlerExecutorPool singleExecutor = new TimeServerHandlerExecutorPool(50, 10000);

while(true) \{

socket = server.accept();

singleExecutor.execute(new TimeServerHandler(socket));

\}

\} catch (IOException e) \{

e.printStackTrace();

\} finally\{

if(null != server) \{

System.out.println("the timeserver is closed");

try \{

server.close();

\} catch (IOException e) \{

e.printStackTrace();

\} finally\{

server = null;

\}

\}

\}

\}

\}

import java.util.concurrent.ArrayBlockingQueue;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.ThreadPoolExecutor;

import java.util.concurrent.TimeUnit;

/\*\*

\* 伪异步IO

\* [@author][author]

\*

\*/

public class TimeServerHandlerExecutorPool \{

private ExecutorService executor;

public TimeServerHandlerExecutorPool(int maxPoolSize, int queueSize) \{

executor = new ThreadPoolExecutor(Runtime.getRuntime().availableProcessors(), maxPoolSize, 120L, TimeUnit.SECONDS, new ArrayBlockingQueue<java.lang.Runnable>(queueSize));

\}

public void execute(java.lang.Runnable task) \{

executor.execute(task);

\}

\}

转载于:https://my.oschina.net/chaun/blog/390893

[80_]: https://my.oschina.net/u/2663968/blog/3051541
[hot3.png]: /images/20220117/6150cb86c7224c2ab2022e946b7556e9.png
[author]: http://my.oschina.net/arthor

发表评论取消回复

表情：

评论列表（有 0 条评论，180人围观）

还没有评论，来说两句吧...

相关阅读

相关 socket.io客户端java

<dependency> <groupId>io.socket</groupId> <a

小灰灰/ 2022年09月03日 05:13/ 0 赞/ 164 阅读

相关异步Socket (.net)

最近在写异步TCP程序，在调试时遇到了Client关闭后程序在接收回调里死循环，用client.Connected 检测好像也没用，在网上找到几篇用Socekt检测的文章，都还

太过爱你忘了你带给我的痛/ 2022年06月12日 12:38/ 0 赞/ 101 阅读

相关 SOCKET.IO

[SOCKET.IO，系统API，][SOCKET.IO_API] 原文：[http://www.cnblogs.com/xiezhengcai/p/3956401.ht

青旅半醒/ 2022年06月02日 03:14/ 0 赞/ 129 阅读

相关 java异步响应式编程

响应式编程响应式编程是一种怎样编程的套路,是一种特殊场景的代码优化. Remote资源 a.查询一个去过的地点 b.查询推荐的目标地点 c.预测目标地点

爱被打了一巴掌/ 2022年05月29日 13:35/ 0 赞/ 203 阅读

相关伪异步IO编程

为了解决BIO（同步阻塞IO）带来的一个链路需要一个线程处理的问题，后来有人对它的线程模型进行了优化，后端通过一个线程池来处理多个客户端的接入，从而形成了一个客户端个数M：线程

╰半夏微凉°/ 2022年05月12日 01:04/ 0 赞/ 124 阅读

相关 java socket伪异步IO式

[为什么80%的码农都做不了架构师？>>> ][80_] ![hot3.png][] import java.io.IOException; import java.net

﹏ヽ暗。殇╰゛Y/ 2022年01月17日 08:19/ 0 赞/ 181 阅读

相关伪异步IO编程

为了改进一线程一连接模型, 后来又演进出了一种通过线程池或者消息队列实现一个或者多个线程处理N个客户端的模型, 通过线程池的方式可以灵活地调配线程资源, 设置线程的最大值

深碍√TFBOYSˉ_/ 2021年09月20日 17:06/ 0 赞/ 303 阅读

相关 Java 非阻塞 IO 和异步 IO

优质文章，及时送达 ![640?wx\_fmt=jpeg][640_wx_fmt_jpeg] 作者 | HongJie 链接 | javadoop.com/post/ni

港控/mmm°/ 2021年07月31日 19:55/ 0 赞/ 340 阅读

相关伪异步IO

前言：同步阻塞IO会有很大的性能问题，那么使用线程池控制呢，就有了伪异步IO，通过线程池对消息队列和最大线程数进行控制，例子见下 package com.honzh.

布满荆棘的人生/ 2021年06月24日 16:09/ 0 赞/ 348 阅读

相关 SOCKET.IO，理解SOCKET.IO

原文：http://www.cnblogs.com/xiezhengcai/p/3957314.html 要理解socket.io ，不得不谈谈websocket 在htm

分手后的思念是犯贱/ 2021年06月10日 20:42/ 1 赞/ 441 阅读