Fixed errors due to missing _thread_id in Python 3.4.0

asphalt/core/application.py

@@ -1,4 +1,5 @@
 from concurrent.futures import ThreadPoolExecutor
+import threading
 from typing import Dict, Any, Union
 from logging import getLogger
 import logging.config
@@ -89,6 +90,7 @@ def run(self):
 
         # This is necessary to make @asynchronous work
         util.event_loop = asyncio.get_event_loop()
+        util.event_loop_thread_id = threading.get_ident()
 
         # Assign a new default executor with the given max worker thread limit
         event_loop = asyncio.get_event_loop()

asphalt/core/util.py

@@ -8,7 +8,7 @@
 __all__ = ('resolve_reference', 'qualified_name', 'synchronous', 'asynchronous',
            'wrap_blocking_api', 'wrap_async_api')
 
-event_loop = None
+event_loop = event_loop_thread_id = None
 
 
 def resolve_reference(ref):
@@ -66,7 +66,7 @@ def synchronous(func: Callable[..., Any]):
 
     @wraps(func, updated=())
     def wrapper(*args, **kwargs):
-        if get_ident() == event_loop._thread_id:
+        if get_ident() == event_loop_thread_id:
             callback = partial(func, *args, **kwargs)
             return event_loop.run_in_executor(None, callback)
         else:
@@ -99,7 +99,7 @@ def callback():
             else:
                 f.set_result(retval)
 
-        if event_loop._thread_id in (get_ident(), None):
+        if event_loop_thread_id in (get_ident(), None):
             return func(*args, **kwargs)
         else:
             f = Future()