PyBitmessage-2025-02-02/src/class_asyncoreThread.py

import asyncore
import shared
import threading

class asyncoreThread(threading.Thread):

    def __init__(self):
        threading.Thread.__init__(self)

    def run(self):
        shared.printLock.acquire()
        print "Asyncore thread started"
        shared.printLock.release()

        while True:
            asyncore.loop(timeout=1) # Despite the horrible parameter name, this function will not timeout until all channels are closed.
            shared.printLock.acquire()
            print("all asyncore modules dead!")
            shared.printLock.release()