import sys, os, time
import threading
class Evaluator (threading.thread):
""" The Evaluator will evaluate and update the status """
def __init__(self):
pass
def queue_not_empty (self):
""" Checks if the ToBeEvaluated queue is empty or not """
pass
def dequeue_attempts (self):
""" Returns an attempt from the ToBeEvaluated queue based on priority
algorithms or return None if queue is empty """
pass
def get_attempt (self):
""" Keep polling the ToBeEvaluated queue until an attempt to be
evaluated is obtained """
while True:
if (self.queue_not_empty()):
return self.dequeue_attempts()
time.sleep (1)
def run (self):
print 'Evaluator Started'
while True:
attempt = self.get_attempt ()
if attempt == None:
continue
# evalute the attempt