include "cefpython.pyx"

g_taskMaxId = 0

g_tasks = {}

def PostTask(int threadId, object func, *args):

PostTaskWrapper(threadId, cTaskId)

cdef public void PyTaskRunnable(int taskId) except * with gil:

cdef object func

cdef list params

cdef object task

try:

global g_tasks

# Validate if task exist.

if str(taskId) not in g_tasks:

raise Exception("PyTaskRunnable failed: invalid taskId=%s" \

% taskId)

# Fetch task: func and params.

task = g_tasks[str(taskId)]

func = task["func"]

params = task["params"]

del g_tasks[str(taskId)]

# Execute user func.

Debug("PyTaskRunnable: taskId=%s, func=%s" % (taskId, func.__name__))

func(*params)

except:

(exc_type, exc_value, exc_trace) = sys.exc_info()

sys.excepthook(exc_type, exc_value, exc_trace)