Semaphore example in python

Semaphore in python

import threading

sem = threading.Semaphore() # or sem = threading.Semaphore(value=n)
sem.acquire()
# Your code here
sem.release()

Semaphore example in python

import threading
import time
import logging

logging.basicConfig(level=logging.DEBUG,
                    format='(%(threadName)-9s) %(message)s',)

class ThreadPool(object):
    def __init__(self):
        super(ThreadPool, self).__init__()
        self.active = []
        self.lock = threading.Lock()
    def makeActive(self, name):
        with self.lock:
            self.active.append(name)
            logging.debug('Running: %s', self.active)
    def makeInactive(self, name):
        with self.lock:
            self.active.remove(name)
            logging.debug('Running: %s', self.active)

def f(s, pool):
    logging.debug('Waiting to join the pool')
    with s:
        name = threading.currentThread().getName()
        pool.makeActive(name)
        time.sleep(0.5)
        pool.makeInactive(name)

if __name__ == '__main__':
    pool = ThreadPool()
    s = threading.Semaphore(3)
    for i in range(10):
        t = threading.Thread(target=f, name='thread_'+str(i), args=(s, pool))
        t.start()

Source: bogotobogo.com

Similar codes

7 votes114 views2 answers
Discord.py reference
Python
2 votes113 views1 answer
Python dictonary of dictonary
Python
1 vote130 views1 answer
Rename the console python
Python
2 votes123 views1 answer
Sqlalchemy query bilter by current month
Python
67 votes141 views6 answers
Deleting duplicates in list python
Python
36 votes127 views4 answers
Python print string in red color
Python
1 vote118 views1 answer
Numpy subarray python
Python
0 vote118 views1 answer
Import system in python
Python
0 vote123 views1 answer
Finding Maximum Elements along columns using Python numpy.argmax()
Python
0 vote168 views1 answer
How to run django server outside world
Python Django