openstack中eventlet使用

zhltom

　　openstack中使用eventlet的协程来实现并发。
　　第一种，使用eventlet.GreenPool来管理绿色线程
　　如l3-agent在开启了8个绿色线程来处理router消息



def _process_routers_loop(self):
pool = eventlet.GreenPool(size=8)
while True:
pool.spawn_n(self._process_router_update)

　　第二种是在oslo.messaging中创建接消息的进程直接创建绿色线程
　　eventlet.spawn()
　　那么在绿色线程到底都走了哪些流程呢？
　　在使用greenlet来创建新的对象的时候，会用调用green_new(tp_new)来创建，后序使用green_init(__init__)来做初始化。在用green_new创建对象时，将此greenlet对象的parent设置为当前的greenlet。



static PyObject* green_new(PyTypeObject *type, PyObject *args, PyObject *kwds)
{
PyObject* o = PyBaseObject_Type.tp_new(type, ts_empty_tuple, ts_empty_dict);
if (o != NULL) {
if (!STATE_OK) {
Py_DECREF(o);
return NULL;
}
Py_INCREF(ts_current);
((PyGreenlet*) o)->parent = ts_current;
}
return o;
}

　　在初始化时将设置了运行函数信息，self->run_info = nrun。
　　在引用greenlet库时，会引用main greenlet，这个是对用户透明的库，所以在使用greenlet库时，除了显式创建的greenlet运行结束之后，还有会运行main greenlet继续执行。
　　在引用模块的时候会调用initModuleName函数来做初始化，对于greenlet库有对应的initgreenlet函数，其中调用了green_create_main来创建main greenlet



static PyGreenlet* green_create_main(void)
{
PyGreenlet* gmain;
PyObject* dict = PyThreadState_GetDict();
/* create the main greenlet for this thread */
gmain = (PyGreenlet*) PyType_GenericAlloc(&PyGreenlet_Type, 0);

gmain->stack_start = (char*) 1;
gmain->stack_stop = (char*) -1;
gmain->run_info = dict;
Py_INCREF(dict);
return gmain;
}
　　在调用 gr.switch的时候会做如下三个动作来完成切换。

• 保存线程状态，即EIP
  
• 进行C栈切换，汇编实现
  
• 恢复目标线程状态，即跳转执行位置
  

　　static PyObject* green_new(PyTypeObject *type, PyObject *args, PyObject *kwds){PyObject* o = PyBaseObject_Type.tp_new(type, ts_empty_tuple, ts_empty_dict);if (o != NULL) {if (!STATE_OK) {Py_DECREF(o);return NULL;}Py_INCREF(ts_current);((PyGreenlet*) o)->parent = ts_current;}return o;}