Apache Thrift的C++多线程编程定式

女爷i 2022-03-06 10:50 158阅读 0赞

Facebook贡献给Apache的开源RPC组件Thrift有着广泛的应用，C++中使用Thrift也十分普遍，但由于Thrift的Handler会被多个线程调用，因而多线程中应用并不直接的友好，利用C++的“thread\_local”特性或GCC的“\_\_thread”特性可化简这一问题。

看具体实例，有一Thrift service：**XService**，编译后生成接口文件**XServiceIf**，接口的实例类为XHandler：

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> class&nbsp;XHandler:&nbsp;public&nbsp;XService { }; </td> 
 </tr> 
 </tbody> 
</table>

由于XHandler会被多个线程调用，直接使用起来需要加锁，不是那么方便。为此引入线程级类**XHelper**：

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> class&nbsp;XHelper { }; </td> 
 </tr> 
 </tbody> 
</table>

XHanlder不做具体的实现，全部委托给XHelper，把XHelper定义为线程级变量：

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> //&nbsp;stg:&nbsp;Static&nbsp;Thread&nbsp;Global #if&nbsp;__cplusplus&nbsp;&lt;&nbsp;201103L &nbsp;&nbsp;&nbsp;&nbsp;static&nbsp;__thread&nbsp;XHelper*&nbsp;stg_xhelper; #else &nbsp;&nbsp;&nbsp;&nbsp;static&nbsp;thread_local&nbsp;XHelper*&nbsp;stg_xhelper; #endif&nbsp;//&nbsp;__cplusplus&nbsp;&lt;&nbsp;201103L </td> 
 </tr> 
 </tbody> 
</table>

新的实现就完全不用关心多线程了：

<table style="width:426.1pt;"> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> static&nbsp;bool&nbsp;init_xhelper()&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(NULL&nbsp;==&nbsp;stg_xhelper)&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;stg_xhelper&nbsp;=&nbsp;new&nbsp;XHelper; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(!stg_xhelper-&gt;init())&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;delete&nbsp;stg_xhelper; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;stg_xhelper&nbsp;=&nbsp;NULL; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;stg_xhelper&nbsp;!=&nbsp;NULL; } &nbsp; void&nbsp;XHandler::foo()&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(init_xhelper())&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;stg_xhelper-&gt;foo(); &nbsp;&nbsp;&nbsp;&nbsp;} } &nbsp; void&nbsp;XHelper::foo()&nbsp;{ } </td> 
 </tr> 
 </tbody> 
</table>