Mercurial > hg > config
view python/multiproc.py @ 602:330e3435a7d7
STUB: python/multiproc.py
author | Jeff Hammel <k0scist@gmail.com> |
---|---|
date | Thu, 30 Jan 2014 14:20:25 -0800 |
parents | 7f189613a289 |
children | bd30deecdf4a |
line wrap: on
line source
#!/usr/bin/env python """ multiprocessing/subprocess experiments """ import argparse import os import subprocess import sys import time import tempfile class Process(subprocess.Popen): """why would you name a subprocess object Popen?""" def __init__(self, *args, **kwargs): self.output = tempfile.SpooledTemporaryFile() subprocess.Popen.__init__(self, *args, **kwargs) # TODO: finish def main(args=sys.argv[1:]): """CLI""" # available programs progs = {'yes': ["yes"], 'ping': ['ping', 'google.com']} # parse command line usage = '%prog [options]' parser = argparse.ArgumentParser(usage=usage, description=__doc__) parser.add_argument("-t", "--time", dest="time", type=float, default=4., help="seconds to run for") parser.add_argument("-s", "--sleep", dest="sleep", type=float, default=1., help="sleep this number of seconds between polling") parser.add_argument("-p", "--prog", dest='program', choices=progs.keys(), help="subprocess to run") # TODO parser.add_argument("--list-programs", help="list available programs") options = parser.parse_args(args) # select program prog = progs[options.program] # start the main subprocess loop # TODO -> OO output = tempfile.SpooledTemporaryFile() start = time.time() proc = subprocess.Popen(prog, stdout=output) location = 0 while proc.poll() is None: curr_time = time.time() run_time = curr_time - start if run_time > options.time: proc.kill() if options.sleep: time.sleep(options.sleep) output.seek(location) read = output.read() location += len(read) print ('[{}] {}\n{}'.format(run_time, read, '-==-'*10)) # reset tempfile output.seek(0) n_lines = len(output.read().splitlines()) print ("{}: {} lines".format(subprocess.list2cmdline(prog), n_lines)) if __name__ == '__main__': main()