diff --git a/aiocassandra.py b/aiocassandra.py
index bf53af9..3c5d7e1 100644
--- a/aiocassandra.py
+++ b/aiocassandra.py
@@ -74,7 +74,7 @@ async def __aenter__(self):
         return self
 
     async def __aexit__(self, *exc_info):
-        self._exit_event.set()
+        self._loop.call_soon_threadsafe(self._finish_event.set)
         _len = len(self._deque)
         self._deque.clear()
         logger.debug(