runtime/PLCObject.py
changeset 2431 6923074540dd
parent 2419 c081dabc0f63
child 2432 dbc065a2f7a5
--- a/runtime/PLCObject.py	Wed Oct 03 15:47:59 2018 +0300
+++ b/runtime/PLCObject.py	Thu Oct 04 11:25:42 2018 +0300
@@ -23,7 +23,6 @@
 
 
 from __future__ import absolute_import
-import thread
 from threading import Thread, Lock, Semaphore, Event, Condition
 import ctypes
 import os
@@ -33,6 +32,7 @@
 import _ctypes  # pylint: disable=wrong-import-order
 import Pyro.core as pyro
 import six
+from six.moves import _thread
 
 from runtime.typemapping import TypeTranslator
 from runtime.loglevels import LogLevelsDefault, LogLevelsCount
@@ -104,7 +104,7 @@
         """
         meant to be called by worker thread (blocking)
         """
-        self._threadID = thread.get_ident()
+        self._threadID = _thread.get_ident()
         if args or kwargs:
             job(*args, **kwargs).do()
             # result is ignored
@@ -128,7 +128,7 @@
 
         _job = job(*args, **kwargs)
 
-        if self._threadID == thread.get_ident() or self._threadID is None:
+        if self._threadID == _thread.get_ident() or self._threadID is None:
             # if caller is worker thread execute immediately
             _job.do()
         else: