您的位置: 首页  >  文章  >  Tomcat源码分析（三）------ 可携带状态的线程池

Tomcat源码分析（三）------ 可携带状态的线程池

分类: 文章 • 2025-07-02 16:27:16

最近想实现一个可携带状态的线程池，具体需求就是池中的线程被用来处理某种信息，而此信息可视为线程所依赖的外部状态。如果用简单的线程池来实现，线程初始化时就得赋予某些信息，使得线程无法被再次利用。在看老版Tomcat的源码时，找到了答案，其实现思路主要是利用了线程的等待和唤起，HttpProcessor的实现正好基于此思路，时序图如下所示：

Tomcat源码分析（三）------ 可携带状态的线程池

初始化HttpProcessor线程时，没法赋予所需的Socket对象，因为如果在初始化阶段就赋予Socket会导致此线程没法回收用来处理其他Socket。因此，在HttpProcessor的run阶段，先把线程给wait住，具体在await方法里体现，代码如下所示：

[java]view plaincopy
  1. /**
  2. *AwaitanewlyassignedSocketfromourConnector,or<code>null</code>
  3. *ifwearesupposedtoshutdown.
  4. */
  5. privatesynchronizedSocketawait(){
  7. //WaitfortheConnectortoprovideanewSocket
  8. while(!available){
  9. try{
  10. wait();
  11. }catch(InterruptedExceptione){
  12. }
  13. }
  15. //NotifytheConnectorthatwehavereceivedthisSocket
  16. Socketsocket=this.socket;
  17. available=false;
  18. notifyAll();
  20. if((debug>=1)&&(socket!=null))
  21. log("Theincomingrequesthasbeenawaited");
  23. return(socket);
  25. }

当HttpConnector调用HttpProcessor.assign(socket)方法时，会给此线程赋予Socket对象，并唤起此线程，使其继续执行，assign方法的源码如下所示：

[java]view plaincopy
  1. /**
  2. *ProcessanincomingTCP/IPconnectiononthespecifiedsocket.Any
  3. *exceptionthatoccursduringprocessingmustbeloggedandswallowed.
  4. *<b>NOTE</b>:ThismethodiscalledfromourConnector'sthread.We
  5. *mustassignittoourownthreadsothatmultiplesimultaneous
  6. *requestscanbehandled.
  7. *
  8. *@paramsocketTCPsockettoprocess
  9. */
  10. synchronizedvoidassign(Socketsocket){
  12. //WaitfortheProcessortogetthepreviousSocket
  13. while(available){
  14. try{
  15. wait();
  16. }catch(InterruptedExceptione){
  17. }
  18. }
  20. //StorethenewlyavailableSocketandnotifyourthread
  21. this.socket=socket;
  22. available=true;
  23. notifyAll();
  25. if((debug>=1)&&(socket!=null))
  26. log("Anincomingrequestisbeingassigned");
  28. }

线程被唤起和赋予socket对象后，继续执行核心的process方法，HttpProcessor.run的完整源码如下所示：

[java]view plaincopy
  1. /**
  2. *ThebackgroundthreadthatlistensforincomingTCP/IPconnectionsand
  3. *handsthemofftoanappropriateprocessor.
  4. */
  5. publicvoidrun(){
  7. //Processrequestsuntilwereceiveashutdownsignal
  8. while(!stopped){
  10. //Waitforthenextsockettobeassigned
  11. Socketsocket=await();
  12. if(socket==null)
  13. continue;
  15. //Processtherequestfromthissocket
  16. try{
  17. process(socket);
  18. }catch(Throwablet){
  19. log("process.invoke",t);
  20. }
  22. //Finishupthisrequest
  23. connector.recycle(this);
  25. }
  27. //TellthreadStop()wehaveshutourselvesdownsuccessfully
  28. synchronized(threadSync){
  29. threadSync.notifyAll();
  30. }
  32. }

相关推荐