import sys
from subprocess import PIPE, Popen
from threading import Thread
from queue import Queue, Empty
ON_POSIX = 'posix' in sys.builtin_module_names
def enqueue_output(out, queue):
for line in iter(out.readline, b''):
queue.put(line)
out.close()
p = Popen(['ping', '-t', 'stackoverflow.com'], stdout=PIPE, bufsize=1, close_fds=ON_POSIX)
q = Queue()
t = Thread(target=enqueue_output, args=(p.stdout, q))
t.daemon = True # thread dies with the program
t.start()
while True:
print(q.get().decode("cp866"))
aW1wb3J0IHN5cwpmcm9tIHN1YnByb2Nlc3MgaW1wb3J0IFBJUEUsIFBvcGVuCmZyb20gdGhyZWFkaW5nICBpbXBvcnQgVGhyZWFkCgpmcm9tIHF1ZXVlIGltcG9ydCBRdWV1ZSwgRW1wdHkKCgpPTl9QT1NJWCA9ICdwb3NpeCcgaW4gc3lzLmJ1aWx0aW5fbW9kdWxlX25hbWVzCgpkZWYgZW5xdWV1ZV9vdXRwdXQob3V0LCBxdWV1ZSk6CiAgICBmb3IgbGluZSBpbiBpdGVyKG91dC5yZWFkbGluZSwgYicnKToKICAgICAgICBxdWV1ZS5wdXQobGluZSkKICAgIG91dC5jbG9zZSgpCgpwID0gUG9wZW4oWydwaW5nJywgJy10JywgJ3N0YWNrb3ZlcmZsb3cuY29tJ10sIHN0ZG91dD1QSVBFLCBidWZzaXplPTEsIGNsb3NlX2Zkcz1PTl9QT1NJWCkKcSA9IFF1ZXVlKCkKdCA9IFRocmVhZCh0YXJnZXQ9ZW5xdWV1ZV9vdXRwdXQsIGFyZ3M9KHAuc3Rkb3V0LCBxKSkKdC5kYWVtb24gPSBUcnVlICMgdGhyZWFkIGRpZXMgd2l0aCB0aGUgcHJvZ3JhbQp0LnN0YXJ0KCkKCgp3aGlsZSBUcnVlOgogICAgcHJpbnQocS5nZXQoKS5kZWNvZGUoImNwODY2IikpCg==