为什么使用线程池?
为了减少瞬间峰值问题，服务器一般都使用线程池，规定了同时并发的最大数量，避免了线程的无限增长.
在浏览器里输出 http://127.0.0.1:8888/
就可以出结果了
Main.java
package com.apq.threadpool;
import com.apq.server.MiniServer;
public class Main {
public static void main(String[] args) {
new EchoServer(8888, 1000).service();
}
}
EchoServer.java
package com.apq.threadpool;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class EchoServer {
//监听的端口号
private final int port;
//单个cpu工作线程数量
private final int poolSize;
private ServerSocket serverSocket;
//线程池
private ThreadPool threadPool;
//jdk线程池
private ExecutorService executorService;
public EchoServer(int port, int poolSize) {
this.port = port;
this.poolSize = poolSize;
//this.threadPool = new ThreadPool(Runtime.getRuntime().availableProcessors() * poolSize);
this.executorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors() * poolSize);
}
//负责为每个客户分配一个线程
public void service() {
try {
serverSocket = new ServerSocket(port);
echo("Listening on " + serverSocket);
while(true) {
echo("Accepting...");
Socket clientSocket = serverSocket.accept();
echo("Connected to " + clientSocket);
//创建一个工作线程并启动(没有线程池的)
//new Thread(new Handler(clientSocket)).start();
//由线程池来处理客户通信
//this.threadPool.putHandler(new Handler(clientSocket));
//用jdk自带的线程池来处理客户通信
this.executorService.execute(new Handler(clientSocket));
}
} catch (IOException e) {
System.err.println(e);
}
}
private void echo(String msg) {
System.out.println(msg);
}
}
ThreadPool.java
package com.apq.threadpool;
import java.util.*;
public class ThreadPool extends ThreadGroup {
private static final int MAX_HANDLER = 100;
// 线程数量
private int poolSize;
// 工作队列
private static LinkedList<Runnable> workQueue;
// 线程池ID
private static int threadPoolID;
// 工作线程ID
private int workThreadPoolID;
private int count;
// 构造函数
public ThreadPool(int poolSize) {
super("ThreadPool-" + (threadPoolID++));
this.poolSize = poolSize;
this.count = 0;
workQueue = new LinkedList<Runnable>();
startWorks();
System.out.println("The EchoServer has started.");
}
// 创建并启动工作线程
private void startWorks() {
for (int i = 0; i < this.poolSize; i++) {
new WorkThread().start();
}
}
// 向工作队列加入一个新任务,由工作线程执行该任务
public synchronized void putHandler(Runnable handler) {
while (count >= MAX_HANDLER) {
try {
wait();
} catch (InterruptedException e) {
}
}
workQueue.add(handler);
count++;
notifyAll();
}
// 从工作队列中取出一个任务,工作线程会调用此方法
public synchronized Runnable getHandler() {
while (count <= 0) {
try {
wait();
} catch (InterruptedException e) {
}
}
Runnable handler = workQueue.removeFirst();
count--;
notifyAll();
return handler;
}
// 内部类 工作线程
private class WorkThread extends Thread {
public WorkThread() {
}
@Override
public void run() {
while (!isInterrupted()) {
Runnable handler = getHandler();
if (handler != null)
handler.run();
}
}
}
}
Handler.java
package com.apq.threadpool;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
//负责与单个客户的通信
public class Handler implements Runnable {
private Socket clientSocket;
public Handler(Socket clientSocket) {
this.clientSocket = clientSocket;
}
@Override
public void run() {
try {
DataOutputStream out = new DataOutputStream(clientSocket
.getOutputStream());
out.writeBytes("HTTP/1.1 200 OK\r\n");
out.writeBytes("Content-type: text/html\r\n");
out.writeBytes("\r\n");
out.writeBytes("<html><head></head><body>");
out.writeBytes("<p>" + "new connection accepted!<br>"
+ clientSocket.getInetAddress() + ":"
+ clientSocket.getPort() + "</p>");
out.writeBytes("</body></html>");
} catch (IOException e) {
//record log
} finally {
if (clientSocket != null)
try {
clientSocket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
分享到：
相关推荐
线程池是一种多线程处理形式，通过预先创建一定数量的线程并管理它们，以提高系统的效率和响应性。在计算机科学中，特别是在软件开发领域，线程池是操作系统或者编程语言中的一种资源管理技术。它允许程序预先启动一...
corePoolSize：核心池的大小，在创建了线程池后，线程池中的线程数为0，当有任务来之后，就会创建一个线程去执行任务，当线程池中的线程数目达到corePoolSize后，就会把到达的任务放到缓存队列当中; ...
阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池阻塞线程池...
一、要实现高效的线程池，可以考虑以下几点 二、实现线程池可以按照以下步骤进行 三、简单的C++线程池代码示例 四、 基于boost编写的源码库 - 线程池 4.1 基于boost编写的源码库地址 4.2 boost线程池的先进先出、...
### 线程池原理及创建（C++实现） #### 一、线程池的重要性 在现代计算环境中，网络服务器面临着处理大量并发请求的挑战，其中包括但不限于Web服务器、电子邮件服务器和数据库服务器。这类服务器通常需要在短时间...
java线程池使用后到底要关闭吗 java线程池是一种高效的并发编程技术，可以帮助开发者更好地管理线程资源，提高系统的性能和可靠性。然而，在使用java线程池时，一个常见的问题是：使用完线程池后到底要不要关闭？...
文章通过实例展示了如何创建一个全局线程池类，该类中封装了线程池对象，并提供了向线程池提交任务、检查任务是否在运行等方法。全局线程池的生命周期与Django主线程的生命周期一致，确保了线程资源的合理释放。 5....
线程池是多线程编程中的一个重要概念，它是一种线程使用模式，通过预先创建一组线程并维护一个线程集合来处理并发任务。在Windows操作系统中，内建的线程池API（Thread Pool API）提供了高效且灵活的线程管理机制，...
线程池是一种在多线程编程中非常重要的概念，它能有效地管理和调度系统中的线程资源，从而提高系统的效率和响应速度。在这个简单的线程池实现中，我们可以通过`pthread_pool.cpp`、`MainFunctionForTest.cpp`、`...
在编程领域，线程池是一种多线程处理形式，处理过程中将任务添加到队列，然后在创建线程后自动启动这些任务。线程池在C++中是提高程序效率和资源管理的重要工具，尤其在处理大量并发操作时。本文将深入探讨VC++中...
Java8并行流中自定义线程池操作示例 Java8并行流中自定义线程池操作示例主要介绍了Java8并行流中自定义线程池操作，结合实例形式分析了并行流的相关概念、定义及自定义线程池的相关操作技巧。 1. 概览 Java8引入了...
Linux 线程池创建 C 实现 线程池是一种常用的并发编程技术，它可以提高应用程序的性能和响应速度。在 Linux 系统中，使用 C 语言创建线程池可以实现高效的并发处理。 什么时候需要创建线程池呢？简单的说，如果一...
DELPHI的线程池（ThreadPool）是一种高效管理并发任务的技术，它允许程序在需要时创建线程，而不是每次需要执行任务时都手动创建。线程池通过预先创建一组线程，然后根据需要分配任务，减少了线程创建和销毁的开销，...
本篇文章将重点探讨两种线程池实现：精易模块线程池和鱼刺模块线程池，并通过源码分析来展示它们的特点和用法。 首先，精易模块（SanYe Module）是由中国程序员SanYe开发的一系列开源模块，其中包含了线程池的实现...
在Linux系统中，线程池是一种高效的进程管理方式，它允许多个任务并行执行，同时限制了系统中并发线程的数量，以优化资源分配和调度。本项目实现了利用线程池进行目录拷贝的功能，这涉及到多个重要的编程概念和技术...
线程池是一种优化资源管理的机制，通过预先创建并维护一组可重用的线程，避免频繁地创建和销毁线程带来的性能开销。在Java、C++等编程语言中，线程池广泛应用于并发处理，提高系统效率，降低系统的资源消耗。本项目...
一、线程池 1、为什么需要使用线程池 1.1 创建/销毁线程伴随着系统开销，过于频繁的创建/销毁线程，会很大程度上影响处理效率。 记创建线程消耗时间T1，执行任务消耗时间T2，销毁线程消耗时间T3，如果T1+T3>T2，那...
线程池管理和多线程上传是并发编程中的一个重要实践，特别是在大数据传输和网络服务中。在Java等编程语言中，线程池通过有效地管理和复用线程资源，避免了频繁创建和销毁线程带来的开销，提升了系统性能。下面将详细...
线程池是多线程编程中一个重要的概念，它能够优化系统资源的使用，提高系统的响应速度和效率。本篇文章将深入探讨C++中的线程池实现，并通过名为“OEasyPool-1.0”的示例来展示其工作原理。 线程池是预先创建并维护...
在C#编程中，线程池（ThreadPool）是一种高效的线程管理机制，它允许开发者创建并管理多个线程，而无需直接操作线程对象。线程池中的线程可以复用，减少了创建和销毁线程的开销。当我们需要执行大量短生命周期的任务...