Merge pull request #94 from pokliu/fix-async-lock-concurrency

Fix async concurrency by replacing threading.RLock with asyncio.Lock

Author: keijack

py_eureka_client/eureka_client.py

@@ -396,7 +396,7 @@ def __init__(self,
         assert ha_strategy in (HA_STRATEGY_RANDOM, HA_STRATEGY_STICK,
                                HA_STRATEGY_OTHER) if should_discover else True, f"do not support strategy {ha_strategy}"
 
-        self.__net_lock = RLock()
+        self.__net_lock = asyncio.Lock()
         self.__eureka_server_conf = EurekaServerConf(
             eureka_server=eureka_server,
             eureka_domain=eureka_domain,
@@ -634,7 +634,7 @@ async def __try_all_eureka_servers(self, fun):
             await self.__try_eureka_server_regardless_zones(fun)
 
     async def __try_eureka_servers_in_list(self, fun, eureka_servers=[], zone=_DEFAUTL_ZONE):
-        with self.__net_lock:
+        async with self.__net_lock:
             ok = False
             _zone = zone if zone else _DEFAUTL_ZONE
             for url in eureka_servers: