#NEWLINE# def __init__( self , maxsize = 0 ) : #NEWLINE# #INDENT# self . maxsize = maxsize #NEWLINE# self . _init ( maxsize ) #NEWLINE# self . mutex = Lock ( ) #NEWLINE# self . not_empty = Condition ( self . mutex ) #NEWLINE# self . not_full = Condition ( self . mutex ) #NEWLINE# self . all_tasks_done = Condition ( self . mutex ) #NEWLINE# self . unfinished_tasks = 0