Dormir un thread bloque stdin

Question

Je cours une fonction qui évalue les commandes passées en utilisant stdin et une autre fonction qui exécute un tas de travaux. J'ai besoin de faire dormir cette dernière fonction à intervalles réguliers mais cela semble bloquer le stdin. Tout conseil sur la façon de résoudre ce problème serait apprécié.

Le code source pour les fonctions est

def runJobs(comps, jobQueue, numRunning, limit, lock): 
    while len(jobQueue) >= 0: 
     print(len(jobQueue)); 
     if len(jobQueue) > 0: 
      comp, tasks = find_computer(comps, 0); 
      #do something 
     time.sleep(5); 

def manageStdin(): 
    print "Global Stdin Begins Now" 
    for line in fileinput.input(): 
     try: 
      print(eval(line)); 
     except Exception, e: 
      print e; 

--Thanks

Answer 1

Utilisez un seul fil:

import time 
import select 
import logging 
import sys 

def stdinWait(interval): 
    start = time.time() 
    while True: 
     time_left = interval - (time.time() - start) 
     if time_left <= 0: 
      break 
     r, w, x = select.select([sys.stdin], [], [], time_left) 
     if r: 
      line = r[0].readline() 
      try: 
       print(eval(line)); 
      except Exception, e: 
       logging.exception(e) 

def runJobs(comps, jobQueue, numRunning, limit, lock): 
    while len(jobQueue) >= 0: 
     print(len(jobQueue)); 
     if len(jobQueue) > 0: 
      comp, tasks = find_computer(comps, 0); 
      #do something 
      stdinWait(5) # wait 5 seconds while watching stdin