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

小鱼儿 2021-12-20 14:53 144阅读 0赞

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

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

<table> 
 <tbody> 
  <tr> 
   <td> <p>class&nbsp;XHandler:&nbsp;public&nbsp;XService</p> <p>{ </p> <p>};</p> </td> 
  </tr> 
 </tbody> 
</table>

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

<table> 
 <tbody> 
  <tr> 
   <td> <p>class&nbsp;XHelper</p> <p>{ </p> <p>};</p> </td> 
  </tr> 
 </tbody> 
</table>

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

<table> 
 <tbody> 
  <tr> 
   <td> <p>//&nbsp;stg:&nbsp;Static&nbsp;Thread&nbsp;Global</p> <p>#if&nbsp;__cplusplus&nbsp;&lt;&nbsp;201103L</p> <p>&nbsp;&nbsp;&nbsp;&nbsp;static&nbsp;__thread&nbsp;XHelper*&nbsp;stg_xhelper;</p> <p>#else</p> <p>&nbsp;&nbsp;&nbsp;&nbsp;static&nbsp;thread_local&nbsp;XHelper*&nbsp;stg_xhelper;</p> <p>#endif&nbsp;//&nbsp;__cplusplus&nbsp;&lt;&nbsp;201103L</p> </td> 
  </tr> 
 </tbody> 
</table>

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

<table> 
 <tbody> 
  <tr> 
   <td> <p>static&nbsp;bool&nbsp;init_xhelper()&nbsp;{ </p> <p>&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(NULL&nbsp;==&nbsp;stg_xhelper)&nbsp;{ </p> <p>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;stg_xhelper&nbsp;=&nbsp;new&nbsp;XHelper;</p> <p>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(!stg_xhelper-&gt;init())&nbsp;{ </p> <p>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;delete&nbsp;stg_xhelper;</p> <p>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;stg_xhelper&nbsp;=&nbsp;NULL;</p> <p>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</p> <p>&nbsp;&nbsp;&nbsp;&nbsp;}</p> <p>&nbsp;&nbsp;&nbsp;&nbsp;return&nbsp;stg_xhelper&nbsp;!=&nbsp;NULL;</p> <p>}</p> <p>&nbsp;</p> <p>void&nbsp;XHandler::foo()&nbsp;{ </p> <p>&nbsp;&nbsp;&nbsp;&nbsp;if&nbsp;(init_xhelper())&nbsp;{ </p> <p>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;stg_xhelper-&gt;foo();</p> <p>&nbsp;&nbsp;&nbsp;&nbsp;}</p> <p>}</p> <p>&nbsp;</p> <p>void&nbsp;XHelper::foo()&nbsp;{ </p> <p>}</p> </td> 
  </tr> 
 </tbody> 
</table>

转载于:https://www.cnblogs.com/aquester/p/10554225.html