cefpython/src/task.pyx at cefpython54 · drbye78/cefpython

drbye78 / cefpython Public

forked from cztomczak/cefpython

Notifications You must be signed in to change notification settings
Fork 0
Star 0

62 lines (47 loc) · 1.63 KB

# Copyright (c) 2012-2014 The CEF Python authors. All rights reserved.
# 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
        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)

FilesExpand file tree

task.pyx

Latest commit

History

task.pyx

File metadata and controls