cefpython/src/task.pyx at cefpython53 · netdebug/cefpython · GitHub

Repository navigation

History

# License: New BSD License.

# Website: http://code.google.com/p/cefpython/

include "cefpython.pyx"

g_taskMaxId = 0

g_tasks = {}

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

global g_tasks, g_taskMaxId

# Validate threadId.

if threadId not in g_browserProcessThreads:

raise Exception("PoastTask failed: requires a browser process thread")

# Validate func.

if not IsFunctionOrMethod(type(func)):

raise Exception("PostTask failed: not a function nor method")

# Params.

cdef list params = list(args)

# Keep func and params until PyTaskRunnable is called.

g_taskMaxId += 1

g_tasks[str(g_taskMaxId)] = {

"func": func,

"params": params

}

# Call C++ wrapper.

cdef int cTaskId = int(g_taskMaxId)

with nogil:

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)

cefpython/src/task.pyx at cefpython53 · netdebug/cefpython · GitHub

Repository navigation

Expand file tree

Breadcrumbs

task.pyx

Latest commit

History

Breadcrumbs

task.pyx

File metadata and controls