# Copyright (c) 2014 CEF Python, see the Authors file.

# All rights reserved. Licensed under BSD 3-clause license.

# Project website: https://github.com/cztomczak/cefpython

include "cefpython.pyx"

g_taskMaxId = 0

g_tasks = {}

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

global g_tasks, g_taskMaxId

# Validate threadId.

if thread not in g_browserProcessThreads:

raise Exception("PostTask 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(thread, cTaskId)

def PostDelayedTask(int thread, int delay_ms, object func, *args):

global g_tasks, g_taskMaxId

# Validate threadId.

if thread not in g_browserProcessThreads:

raise Exception("PostTask 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:

PostDelayedTaskWrapper(thread, delay_ms, 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)