1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
|
# -*- encoding: utf-8 -*-
# Pilas engine - A video game framework.
#
# Copyright 2010 - Hugo Ruscitti
# License: LGPLv3 (see http://www.gnu.org/licenses/lgpl.html)
#
# Website - http://www.pilas-engine.com.ar
class Tarea(object):
def __init__(self, time_out, dt, funcion, parametros, una_vez):
"""
Parametros:
- time_out: el tiempo absoluto para ejecutar la tarea.
- dt: la frecuencia de ejecución.
- funcion: la funcion a invocar.
- parametros: una lista de argumentos para la funcion anterior.
- una_vez: indica si la funcion se tiene que ejecutar una sola vez.
"""
self.time_out = time_out
self.dt = dt
self.funcion = funcion
self.parametros = parametros
self.una_vez = una_vez
self.activa = True
def ejecutar(self):
return self.funcion(*self.parametros)
def eliminar(self):
self.activa = False
class TareaCondicional(Tarea):
def ejecutar(self):
retorno = Tarea.ejecutar(self)
if not retorno:
self.una_vez = True
class Tareas(object):
"""Contenedor de tareas a ejecutar por tiempo.
El Tareas es un planificador de tareas, permite que
podamos ejecutar funciones y métodos luego de transcurrido
el tiempo que queramos.
Por ejemplo, si se quiere que el planificardor ejecute
una función dentro de dos segundos podemos escribir:
pilas.mundo.agregar_tarea(2, hola)
o bien, especificando argumentos para esa función:
pilas.mundo.agregar_tarea(4, hola, 'persona')
La función que se especifique como segundo argumento
tiene que retornar True o False. Si retorna True será
colocada nuevamente en la cola de tareas una vez que se
ejecute (esto es útil para crear bucles).
"""
def __init__(self):
self.tareas_planificadas = []
self.contador_de_tiempo = 0
def actualizar(self, dt):
"Actualiza los contadores de tiempo y ejecuta las tareas pendientes."
self.contador_de_tiempo += dt
to_remove = []
for tarea in self.tareas_planificadas:
if self.contador_de_tiempo > tarea.time_out:
if tarea.activa:
tarea.ejecutar()
if tarea.una_vez:
self.tareas_planificadas.remove(tarea)
else:
w = self.contador_de_tiempo - tarea.time_out
parte_entera = int((w)/float(tarea.dt))
resto = w - (parte_entera * tarea.dt)
for x in range(parte_entera):
tarea.ejecutar()
tarea.time_out += tarea.dt + (parte_entera * tarea.dt) - resto
else:
self.tareas_planificadas.remove(tarea)
def _agregar(self, tarea):
"Agrega una nueva tarea para ejecutarse luego."
self.tareas_planificadas.append(tarea)
def una_vez(self, time_out, function, params=[]):
tarea = Tarea(self.contador_de_tiempo + time_out, time_out, function, params, True)
self._agregar(tarea)
return tarea
def siempre(self, time_out, function, params=[]):
tarea = Tarea(self.contador_de_tiempo + time_out, time_out, function, params, False)
self._agregar(tarea)
return tarea
def condicional(self, time_out, function, params=[]):
tarea = TareaCondicional(self.contador_de_tiempo + time_out, time_out, function, params, False)
self._agregar(tarea)
return tarea
|
