Cfrgtkky

I have a connection pool (ThreadedConnectionPool) and threads that when I'm executing I get a connection from the pool, does all it's stuff and then release connection by putconn(), but if I do this inside the thread it doesn't release properly the connection and gets "connection pool exhausted". I tryed doing this outside the thread and everything's fine. I passed the connection pool to the thread's executed function but it doesn't work anyway. Any idea? Thank you.

dbconn_pool = psycopg2.pool.ThreadedConnectionPool(minconn=1, maxconn=3,

                                                                  host="XXX",

                                                                  port="XXX",

                                                                  dbname="XXX",

                                                                  user="XXX",

                                                                  password="XXX")



def processing_informations(conn_pool):

    db_connection = conn_pool.getconn()

    db_connection.set_session(readonly=True, autocommit=True)

    cur = db_connection.cursor(cursor_factory=RealDictCursor)

    .....more....

    conn_pool.putconn(db_connection)



def start_processor():

    new_thread = threading.Thread(target=self.processing_informations, args=[dbconn_pool])

    new_thread.daemon = True

    new_thread.start()



while true:

    start_processor()

    sleep(100)