这个例子里面其实是将异常退出处理和正常退出处理结合起来了。对于SIGTERM(即kill进程)和SIGINT(即ctrl-c结束前台进程),我们当做是正常退出,在其信号处理函数里面,直接调用了exit(0),而exit(0)又会被server_on_exit捕获到。对于异常退出也是类似,只是调用了exit(-1)表示是异常的。同时异常退出我们会打印出当前的进程堆栈信息,server_backtrace的实现下一篇再说。另外注意的是SIGKILL信号是无法捕获的。而调用abort导致的退出,也是通过SIGABRT信号捕获到进行处理了。其他几种异常退出的信号也是比较常见,一并捕获到进行处理。这样对于异常退出,我们即可统一的log堆栈信息,又可直接继续正常退出时的处理流程了。
在我们日常生活中会遇到许许多多的问题,如果一个服务端要接受很多客户端的数据,该怎么办?多线程并发内存不够怎么办?所以我们需要了解线程池的相关知识。
1.线程池的简介
线程池是一种多线程处理形式,处理过程中将任务添加到队列,然后在创建线程后自动启动这些任务。线程池线程都是后台线程。每个线程都使用默认的堆栈大小,以默认的优先级运行,并处于多线程单元中。如果某个线程在托管代码中空闲(如正在等待某个事件),则线程池将插入另一个辅助线程来使所有处理器保持繁忙。如果所有线程池线程都始终保持繁忙,但队列中包含挂起的工作,则线程池将在一段时间后创建另一个辅助线程但线程的数目永远不会超过最大值。超过最大值的线程可以排队,但他们要等到其他线程完成后才启动。
2.线程池的组成
1、线程池管理器(ThreadPoolManager):用于创建并管理线程池
2、工作线程(WorkThread): 线程池中线程
3、任务接口(Task):每个任务必须实现的接口,以供工作线程调度任务的执行。
4、任务队列:用于存放没有处理的任务。提供一种缓冲机制。
3.线程池的主要优点
1.避免线程太多,使得内存耗尽
2.避免创建与销毁线程的代价
3.任务与执行分离
1.线程池结构体定义
代码如下(示例):
相关视频推荐
150行代码,带你手写线程池,自行准备linux环境
C++后台开发该学哪些内容,标准技术路线及面经与算法该如何刷
学习地址:C/C++Linux服务器开发/后台架构师【零声教育】-学习视频教程-腾讯课堂
需要更多C/C++ Linux服务器架构师学习资料加qun 812855908 (资料包括C/C++,Linux,golang技术,内核,Nginx,ZeroMQ,MySQL,Redis,fastdfs,MongoDB,ZK,流媒体,CDN,P2P,K8S,Docker,TCP/IP,协程,DPDK,ffmpeg,大厂面试题 等)
2.接口定义
代码如下(示例):
3.回调函数
代码如下(示例):
4.全部代码(加注释)
代码如下(示例):
关于线程池是基本代码就在上面了,关于编程这一部分内容,我建议大家还是要自己去动手实现,如果只是单纯的看了一遍,知识这块可能会记住,但是 *** 作起来可能就比较吃力,万事开头难,只要坚持下去,总会有结果的。
1.SQLite数据库特点(1)SQLite数据库是开源的嵌入式数据库,无需独立的数据库引擎,直接嵌入到应用程序进程中,因此,通过API,应用程序可以直接 *** 作它。(2)事务的处理是原子的,一致的,独立的,可持久化的(ACID),即使在系统崩溃和掉电后。(3)SQLite数据库通过独占性与共享锁来实现事务的独立处理。(4)一个单独的跨平台的磁盘文件就能够存储一个数据库。(5)能支持2TB级的数据。(6)自包含,无外部依赖性。(7)支持NULL,INTEGER,NUMERIC,REAL,TEXT和BLOG等数据类型。(8)SQLite数据库没有用户帐户的概念。数据库的权限仅依赖于文件系统。2.SQLite数据库的基本 *** 作(1)建立数据库sqlite3data.sqlite3在当前目录下建立了名为data.sqlite3的数据库。(2)建立数据表createtablecall_list(idINTEGERPRIMARYKEY,typeNUMERIC,telnumNUMERIC,bttimeTEXT,tcountNUMERIC,charge_rateNUMERIC,charge_sumNUMERIC)建立了名为call_list的数据表,有7个字段,分别为id,type,telnum,bttime,tcount,charge_sum.charge_rate.(3)向数据表中插入数据insertintocall_listvalues($num,1,2,'new',4,5,6)(4)查询数据表中的数据select*fromcall_list(5)修改call_list表中的数据updatecall_listsetid=00001000whereid=10001(6)删除表中的数据记录deletefromcall_listwhereid=1000(7)SQlite中的其它常用命令.tables-列出所有的数据库中的数据表.schematablename-列出指定数据表的结构.quit-离开数据库(8)SQLite数据库的导入与导出a.将data.sqlite数据库的数据全部导出:sqlite3data.sqlite>.outputdd.sql>.dump这样,数据就保存在dd.sql的文件中,注意这个文件不是数据库,而是SQL语句。然后再把这些数据导入到另外一个数据库data1.sqlite数据库中。sqlite3data1.sqlite>.readdd.sql这样,数据就从data.sqlite数据库复制到data1.sqlite数据库中去了。b.将数据表中的数据导出到a.txt中去.outputa.txt//输出重定向到a.txtselect*fromcall_listc.将导出的表中的数据导入到另一个数据库的新建的表中去如:当从data.sqlite中的call_list表中导出了数据,再导入到另外一个数据库表call中去。首先建立表call.然后.importa.txtcall即可。3.C语言 *** 作Sqlite数据库API:intsqlite3_open(constchar*filename,sqlite3**ppdb)第一个参数用来指定数据库文件名。第二个参数是一个数据库标识符指针。如果打开数据库成功,则返回0,否则返回一个错误代码。intsqlite3_close(sqlite3*)传递的参数是数据库标识符指针用来关闭数据库, *** 作成功是返回0,否则返回一个错误代码。intsqlite3_errcode(sqlite3*db)constchar*sqlite3_errmsg(sqlite3*db)constchar*sqlite3_errmsg16(sqlite3*db)这三个函数都是返回错误信息,第一个函数返回的是最近调用数据库接口的错误代码,第二,第三个函数是返回最近调用数据库接口的错误信息。第二个函数返回的错误信息是用UTF-8编码的,第三个函数返回的错误信息是用UTF-16编码的。intsqlite3_exec(sqlite3*,constchar*sql,int(*callback)(void*,int,char**,char**),void*,**errmsg)这个函数非常重用,是用来执行SQLite数据库的SQL语句的。第一个参数是sqlite数据库标识符指针。第二个参数是要执行的SQL语句。第三个参数是一个回调函数,在执行查询 *** 作时用到,其它的 *** 作可以传空值即NULL。第四个参数是传递给回调函数第一个参数的实参。第五个参数是一个错误信息。回调函数:intcallback(void*,intargc,char**argv,char**cname)第一个参数是从sqlite3_exec传递过来的参数,可以为任意的类型。第二个参数是查询的列数。第三个参数是查询结果集的值。第四个参数是列名。intsqlite3_get_table(sqlite3*db,constchar*sql,char***result,int*row,int*col,char**errmsg)这个函数主要是用来查询的。第一个参数是数据库描述符指针第二个参数是SQL语句。第三个参数是查询的结果集。第四个参数是结果集中的行数。第五个参数是结果集中的列数。第六个参数是错误信息。它查询出的行数是从字段名开始的。即第0行是字段名。实例:/**本例主要实现用Sqlite的回调函数进行查询intsqlite3_exec(sqlite3*,constchar*sql,int(*callback)(void*,int,char**,char**),void*,errmsg)第一个参数是数据库标识符第二个参数是要执行的sql命令第三个参数是回调函数第四个参数是回调函数的第一个参数第五个参数是用于指示错误信息其中回调函数的形式:int_sql_callback(void*arg,intargc,char**argv,char**cname)第二个参数指示结果集中的列数第三个参数是保存结果集的字符串第四个参数是结果集中的列名**/#include#include#include#include#include#includeint_call_back(void*arg,intargc,char**argv,char**cname)intmain(){intresconstchar*dbfile="data.sqlite1"char*errmsg=NULLsqlite3*dbres=sqlite3_open(dbfile,&db)if(res!=0){perror("数据库打开失败")exit(EXIT_FAILURE)}//创建一张数据表constchar*sqlcreate="createtablecall_list(idINTEGERPRIMARYKEY,typeNUMERIC,telnumNUMERIC,bttimeTEXT,tcountNUMERIC,charge_rateNUMERIC,charge_sumNUMERIC)"res=sqlite3_exec(db,sqlcreate,NULL,NULL,&errmsg)if(res!=0){perror("建立数据表失败")exit(EXIT_FAILURE)}//插入100000条数据intnum=0structtimevaltvgettimeofday(&tv,NULL)longold=tv.tv_secwhile(num<100000){constchar*sqlinsert="insertintocall_listvalues($num,1,2,'new',4,5,6)"res=sqlite3_exec(db,sqlinsert,NULL,NULL,&errmsg)//插入时不需要用到回调函数if(res!=0){perror("插入失败")exit(EXIT_FAILURE)}num++}gettimeofday(&tv,NULL)printf("插入100000条数据的时间为:%d秒/n",(tv.tv_sec-old))//更新constchar*sqlupdate="updatecall_listsetid=00001000whereid=10001"res=sqlite3_exec(db,sqlupdate,NULL,NULL,&errmsg)if(res!=0){perror("更新数据失败")exit(EXIT_FAILURE)}//删除constchar*sqldelete="deletefromcall_listwhereid=1000"res=sqlite3_exec(db,sqldelete,NULL,NULL,&errmsg)if(res!=0){perror("删除数据失败")exit(EXIT_FAILURE)}//查询constchar*sqlquery="select*fromcall_list"res=sqlite3_exec(db,sqlquery,&_call_back,NULL,&errmsg)if(res!=0){printf("%s/n",errmsg)perror("执行失败/n")exit(EXIT_FAILURE)}res=sqlite3_close(db)if(res!=0){perror("数据库关闭失败")exit(EXIT_FAILURE)}exit(EXIT_SUCCESS)}int_call_back(void*arg,intargc,char**argv,char**cname){inti//二重指针可以看成指针数组for(i=0i欢迎分享,转载请注明来源:内存溢出
评论列表(0条)