#NEWLINE# def __init__( self , vdm , offlineCache ) : #NEWLINE# #INDENT# Stoppable . Stoppable . __init__ ( offlineCache ) #NEWLINE# self . dependencies_ = TwoWaySetMap . TwoWaySetMap ( ) #NEWLINE# self . vdm_ = vdm #NEWLINE# self . offlineCache_ = offlineCache #NEWLINE# self . finishedValues_ = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } #NEWLINE# self . intermediates_ = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } #NEWLINE# self . lock_ = threading . RLock ( ) #NEWLINE# self . completable_ = Queue . Queue ( ) #NEWLINE# self . timesComputed = 0 #NEWLINE# self . computingContexts_ = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } #NEWLINE# self . computingContexts_t0_ = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } #NEWLINE# self . isSplit_ = set ( ) #NEWLINE# self . watchers_ = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } #NEWLINE# self . contexts_ = [ ] #NEWLINE# self . inProcessDownloader = OutOfProcessDownloader . OutOfProcessDownloaderPool ( Setup . config ( ) . cumulusServiceThreadCount , actuallyRunOutOfProcess = False ) #NEWLINE# self . threads_ = [ ] #NEWLINE# self . isActive = True #NEWLINE# for threadIx in range ( Setup . config ( ) . cumulusServiceThreadCount ) : #NEWLINE# #INDENT# workerThread = ManagedThread . ManagedThread ( target = self . threadWorker ) #NEWLINE# workerThread . start ( ) #NEWLINE# self . threads_ . append ( workerThread )