在spring.xml 文件中配置：



<!--  线程-->
    <bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">  
        <!-- 核心线程数 -->       
        <property name="corePoolSize" value="2" />  
        <!-- 最大线程数 -->    
        <property name="maxPoolSize" value="5" />  
        <!-- 队列最大长度 -->  
        <property name="queueCapacity" value="10" />  
        <!-- 线程池维护线程所允许的空闲时间，默认为60s -->  
        <property name="keepAliveSeconds" value="200" />  
    </bean>  


然后在要使用的服务中注入：



     /**
   * 引入线程
   */
  @Resource
  private TaskExecutor taskExecutor;


在方法中直接使用即可：

1,常规用法

    //获取线程执行时间计算
    taskExecutor.execute(new Runnable() {
        @Override
        public void run() {

            .........
        }
    });






2，调整优先级



Thread thread= new Thread(new Runnable() {
@Override
public void run() {
...................
}
});
thread.setPriority(10);
taskExecutor.execute(thread);

“`

为什么要在操作系统中引入线程？
答：由于进程是资源的拥有者，所以在创建、撤销、切换操作中需要较大的时空开销，限制了并发程度的进一步提高。为减少进程切换的开销，把进程作为资源分配单位和调度单位这两个属性分开处理，即进程还是作为资源分配的基本单位，但是不作为调度的基本单位（很少调度或切换），把调度执行与切换的责任交给“线程”。这样做的好处不但可以提高系统的并发度，还能适应新的对称多处理机（SMP）环境的运行，充分发挥其性能。

引入线程的原因
一：进程与线程的结构

进程1=资源+指令




@资源
1指令



进程2=资源+指令




@资源
2指令



线程=资源+多个指令*

线程1=资源+多个指令




资源
指令1，指令2，.。。。。



二：原因！

在说原因之前先引入一个概念服务器，在这里服务器就相当于内存！

服务器：




@资源#资源￥资源
%资源&资源*资源








当我们每打开一个网页的时候，大多都包含很多内容，具体有文本，图片，视频等等。这里只是简单举例说明引入线程的原因。
它的内部实现是先 从服务器上内容，然后再显示到网页上！！说的具体一点其实就是两步。一：下载 ，二：显示。
那现在就让

进程1负责下载；

进程2负责显示；
进程1从服务器上下载资源（@资源），指令1就是下载资源的命令（各种语言代码）；

进程2要想显示还得从进程1中获取资源（@资源），然后指令2执行显示命令（各种语言代码）；
进程1从进程2中获取资源（@资源）这无疑加大了进程调度的时空开销，为了减少了资源的调度，从而减少了进程调度的开销！与是引入了线程！
说明：本文章内容仅供参考，实属本人的个人理解，如有错误，请及时在评论区下方留言！

让我们一起学习，共同进步！！！

文章目录
1 客户端引入多线程

1 客户端引入多线程

我们在客户端引入多线程，示例代码如下：
#include "EasyTcpClient.hpp"
#include<thread>

bool g_bRun = true;
void cmdThread()
{
	while (true)
	{
		char cmdBuf[256] = {};
		scanf("%s", cmdBuf);
		if (0 == strcmp(cmdBuf, "exit"))
		{
			g_bRun = false;
			printf("退出cmdThread线程\n");
			break;
		}
		else {
			printf("不支持的命令。\n");
		}
	}
}

//客户端数量
const int cCount = 10000;
//发送线程数量
const int tCount = 4;
//客户端数组
EasyTcpClient* client[cCount];

void sendThread(int id)
{
	//4个线程 ID 1~4
	int c = cCount / tCount;
	int begin = (id - 1)*c;
	int end = id*c;

	for (int n = begin; n < end; n++)
	{
		client[n] = new EasyTcpClient();
	}
	for (int n = begin; n < end; n++)
	{
		client[n]->Connect("192.168.1.110", 4567);
		printf("thread<%d>,Connect=%d\n", id,n);
	}

	//std::chrono::milliseconds t(5000);
	//std::this_thread::sleep_for(t);

	Login login[10];
	for (int n = 0; n < 10; n++)
	{
		strcpy(login[n].userName, "lyd");
		strcpy(login[n].PassWord, "lydmm");
	}
	const int nLen = sizeof(login);
	while (g_bRun)
	{
		for (int n = begin; n < end; n++)
		{
			client[n]->SendData(login, nLen);
			//client[n]->OnRun();
		}
	}

	for (int n = begin; n < end; n++)
	{
		client[n]->Close();
	}
}

int main()
{
	//启动UI线程
	std::thread t1(cmdThread);
	t1.detach();

	//启动发送线程
	for (int n = 0; n < tCount; n++)
	{
		std::thread t1(sendThread,n+1);
		t1.detach();
	}

	while (g_bRun)
		Sleep(100);

	printf("已退出。\n");
	return 0;
}


参考资料：

C++ 百万并发网络通信引擎架构与实现 （服务端、客户端、跨平台） Version 1.0