switched from threading to multiprocessing

functions same, just keeping names from confusing people
pull/14899/head
Brian Coca 9 years ago committed by James Cammarata
parent fa3f5c1de9
commit d743709c1a

@ -21,7 +21,7 @@ import collections
import os
import sys
import time
import threading
from multiprocessing import Lock
from itertools import chain
from ansible import constants as C
@ -53,7 +53,7 @@ class ProxyClientPool(object):
self._num_connections = 0
self._available_connections = collections.deque(maxlen=self.max_connections)
self._locked_connections = set()
self._lock = threading.Lock()
self._lock = Lock()
def _check_safe(self):
if self.pid != os.getpid():

Loading…
Cancel
Save