java socket伪异步IO式

﹏ヽ暗。殇╰゛Y 2022-01-17 08:19 242阅读 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 条评论，242人围观）

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

相关阅读

相关异步Socket (.net)

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

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

相关 SOCKET.IO

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

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

相关图片伪异步上传

首先我们来讲讲前端的页面代码如何写： <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">

叁歲伎倆/ 2022年05月24日 11:54/ 0 赞/ 275 阅读

相关伪异步IO编程

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

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

相关伪异步 I/O 编程

目录本文导读伪异步 I/O 总结 -------------------- ![watermark_type_ZmFuZ3poZW5naGVpdGk_shado

r囧r小猫/ 2022年05月08日 15:52/ 0 赞/ 178 阅读

相关 java socket伪异步IO式

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

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

相关 Netty学习-伪异步BIO

上一节我们讲了最最传统的BIO，该BIO十分浪费资源，因为其一对一线程的特性。于是出现了伪异步的I/O编程伪异步的I/O模型采用线程池和任务队列。当由新的客户端接入时

超、凢脫俗/ 2021年11月06日 00:20/ 0 赞/ 350 阅读

相关伪异步IO编程

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

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

相关伪异步IO

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

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

相关 SOCKET.IO，理解SOCKET.IO

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

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