使用psycopg2与绿线程的连接冲突问题及相关咨询

psycopg2是否存在隐式连接池？ #

psycopg2本身没有内置的隐式连接池，默认情况下，每次调用psycopg2.connect()都会创建一个全新的数据库连接，对应独立的底层套接字，不会复用之前的连接资源。

为什么会出现多绿线程读同一套接字的错误？ #

你遇到的错误本质是多个绿线程共享了同一个数据库连接实例。尽管你没显式配置连接池，但代码中可能存在连接对象被意外复用的情况（比如连接被全局存储、在绿线程间传递共享）。绿线程基于用户态调度，多个绿线程同时操作同一个连接的套接字时，eventlet的调试机制会检测到这种冲突并抛出错误。

如何获取不复用旧连接/套接字的新连接？ #

• 严格隔离连接归属：确保每个绿线程都独立调用psycopg2.connect()获取专属连接，绝对不要在多个绿线程间共享同一个连接对象。示例代码：

  def green_thread_task():
      conn = psycopg2.connect("dbname=test user=postgres")
      # 执行数据库操作
      conn.close()
  

• 使用适配绿线程的连接池：如果需要复用连接以提升性能，不要手动共享连接，改用eventlet提供的pools.Pool来管理连接，它会确保同一时间只有一个绿线程使用某个连接。示例代码：

  from eventlet import pools
  
  class DBConnectionPool(pools.Pool):
      def create(self):
          return psycopg2.connect("dbname=test user=postgres")
  
  pool = DBConnectionPool(max_size=10)
  
  def green_thread_task():
      with pool.acquire() as conn:
          # 执行数据库操作
          pass
  

• 临时规避（不推荐）：如果你明确知道自己的操作不会引发问题，可调用eventlet.debug.hub_prevent_multiple_readers(False)关闭该检测，但这可能隐藏并发访问导致的数据错乱或连接异常风险。

内容的提问来源于stack exchange，提问作者lmat - Reinstate Monica