标签：.__ logging self acquire 信号量 error Semaphore pool

和Lock很像,信号量对象内部维护一个倒计算器,每次调用acquire()都会 -1 , 当acquire()时,计算器为0就会阻塞请求线程,直到其它线程对信号量 release()后,计数器 +1,恢复阻塞线程

计数器永远>=0

import threading,logging,time
FORMAT='%(asctime)-15s\t [ %(threadName)s %(thread)8d ] %(message)s'
logging.basicConfig(level=logging.ERROR,format=FORMAT)

def w(barrier:threading.Semaphore):
    logging.error('in sub thread')
    logging.error(s.acquire())
    logging.error('sub thread over')

s=threading.Semaphore(3)

logging.error(s.acquire())
logging.error(s.acquire())
logging.error(s.acquire())
# logging.error(s.acquire())
threading.Thread(target=w,args=(s,)).start()
threading.Event().wait(2)
logging.error(s.acquire(blocking=False))
logging.error(s.acquire(timeout=3))
logging.error(s.release())

连接池:

连接池应该有容量,有一个工厂方法可以获取连接,能够把不用的连接返回

import threading,logging,time
FORMAT='%(asctime)-15s\t [ %(threadName)s %(thread)8d ] %(message)s'
logging.basicConfig(level=logging.ERROR,format=FORMAT)

class Conn:
    def __init__(self,name):
        self.name=name

class Pool:
    def __init__(self,num,C:Conn):
        self.num=num
        self.__pool=[C('conn-{}'.format(b)) for b in range(num)]
        self.semaphore=threading.Semaphore(num)

    def acquire(self):
        # if len(self.__pool)>0:
        #     return self.__pool.pop()
        # else:
        #     return None
        self.semaphore.acquire()
        return self.__pool.pop()

    def release(self,conn:Conn):
        self.__pool.append(conn)
        self.semaphore.release()

pool=Pool(3,Conn)
pool.acquire()
pool.acquire()
pool.acquire()

class Conn:
    def __init__(self,name):
        self.name=name

class Pool:
    def __init__(self,num:int):
        self.num=num
        self.__pool=[self.__connect('conn-{}'.format(b)) for b in range(self.num)]
    def __connect(self,name):
        return Conn(name)
    
    def acquire(self):
        if len(self.__pool)>0:
            return self.__pool.pop()
        else:
            pass
    
    def release(self,conn:Conn):
        self.__pool.append(conn)
    
    
        

上面acquire()方法,在多线程的时候,有线程安全问题

假设池中正好有一个链接,有可能多个线程判断池的长度是>0的,当一个线程拿走了连接对象,其他线程再来pop就会抛异常?

• 加锁,在读写的地方加锁
• 使用信号量Semaphore
  
  

标签：.__,logging,self,acquire,信号量,error,Semaphore,pool
来源： https://www.cnblogs.com/dissipate/p/13876223.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。