def put(self, segment):
if self.closed:<EOL><INDENT>return<EOL><DEDENT>if segment is not None:<EOL><INDENT>future = self.executor.submit(self.fetch, segment,<EOL>retries=self.retries)<EOL><DEDENT>else:<EOL><INDENT>future = None<EOL><DEDENT>self.queue(self.futures, (segment, future))<EOL>
Adds a segment to the download pool and write queue.