#NEWLINE# def startjoin( context , scatters ) : #NEWLINE# #INDENT# gather = GatherProcess ( ) #NEWLINE# context . spawn ( gather ) #NEWLINE# for scatter in scatters : #NEWLINE# #INDENT# scatter . start ( ) #NEWLINE# #UNINDENT# for scatter in scatters : #NEWLINE# #INDENT# scatter . join ( ) #NEWLINE# #UNINDENT# for scatter in scatters : #NEWLINE# #INDENT# assert scatter . success