|
@@ -4,7 +4,6 @@ import ctypes
|
|
|
import glob
|
|
|
import os
|
|
|
import sys
|
|
|
-import threading
|
|
|
import time
|
|
|
|
|
|
import zmq
|
|
@@ -12,10 +11,11 @@ import zmq.auth
|
|
|
|
|
|
from aman.com import AircraftReport_pb2
|
|
|
from aman.config.Server import Server
|
|
|
+from threading import Thread, _active
|
|
|
|
|
|
-class ReceiverThread(threading.Thread):
|
|
|
+class ReceiverThread(Thread):
|
|
|
def __init__(self, socket, aman):
|
|
|
- threading.Thread.__init__(self)
|
|
|
+ Thread.__init__(self)
|
|
|
self.socket = socket
|
|
|
self.aman = aman
|
|
|
|
|
@@ -41,7 +41,7 @@ class ReceiverThread(threading.Thread):
|
|
|
def threadId(self):
|
|
|
if hasattr(self, '_thread_id'):
|
|
|
return self._thread_id
|
|
|
- for id, thread in threading._active.items():
|
|
|
+ for id, thread in _active.items():
|
|
|
if thread is self:
|
|
|
return id
|
|
|
|