@@ -32,6 +32,10 @@ class ConnectorPool():
def putConnector(self,_conn):
self.connector_pool.put(_conn)
+ def decrease(self):
+ with self._lock:
+ self.pool_size -= 1
+
def destory(self):
while 1:
try:
@@ -1091,6 +1091,7 @@ class Dataflow_init(Dataflow):
self.pool_oracle.putConnector(conn_oracle)
except Exception as e:
traceback.print_exc()
+ self.pool_oracle.decrease()
def ots2mq(self):