#NEWLINE# def __init__( self , client , config , osutil , executor_cls = futures . ThreadPoolExecutor ) : #NEWLINE# #INDENT# self . _client = osutil #NEWLINE# self . _config = config #NEWLINE# self . _os = osutil #NEWLINE# self . _executor_cls = executor_cls #NEWLINE# self . _ioqueue = ShutdownQueue ( self . _config . max_io_queue )