%s URLs." % (time.time() - start, len(fetched))) print("Unable to fetch %s URLs." % len(dead)) # Signal all the workers to exit. for _ in range(concurrency): await q.put(None) await workers if __name__ next I/O loop iteration. It is safe to call this method from any thread at any time, except from a signal handler. Note that this is the only method in IOLoop that makes this thread-safety guarantee; all add_callback_from_signal(callback: Callable, *args: Any, **kwargs: Any) → None Calls the given callback on the next I/O loop iteration. Intended to be afe for use from a Python signal handler; should not

(time.time() - start, len(fetched))) print("Unable to fetch %s URLs." % len(dead)) # Signal all the workers to exit. for _ in range(concurrency): await q.put(None) await workers update_handler() IOLoop.remove_handler() Callbacks and timeouts IOLoop.add_callback() IOLoop.add_callback_from_signal() IOLoop.add_future() IOLoop.add_timeout() IOLoop.call_at() IOLoop.call_later() IOLoop.remove_timeout() next I/O loop iteration. It is safe to call this method from any thread at any time, except from a signal handler. Note that this is the only method in IOLoop that makes this thread-safety guarantee; all

you're writing a digital filtering algorithm and you have a method that handles the edges of the signal by applying padding: function myfilter(A, kernel, ::Replicate) Apadded = replicate_edges(A, size(kernel)) which is called at various events during a worker's lifetime (for example, sending an interrupt signal) addprocs(manager::FooManager) requires FooManager to implement: function launch(manager::FooManager :interrupt when interrupt(workers) is called. The ClusterManager should signal the ap- propriate worker with an interrupt signal. • with :finalize for cleanup purposes.CHAPTER 25. MULTI-PROCESSING AND

you're writing a digital filtering algorithm and you have a method that handles the edges of the signal by applying padding: function myfilter(A, kernel, ::Replicate) Apadded = replicate_edges(A, size(kernel)) which is called at various events during a worker's lifetime (for example, sending an interrupt signal) addprocs(manager::FooManager) requires FooManager to implement: function launch(manager::FooManager :interrupt when interrupt(workers) is called. The ClusterManager should signal the ap- propriate worker with an interrupt signal. • with :finalize for cleanup purposes.CHAPTER 25. MULTI-PROCESSING AND

you're writing a digital filtering algorithm and you have a method that handles the edges of the signal by applying padding: function myfilter(A, kernel, ::Replicate) Apadded = replicate_edges(A, size(kernel)) which is called at various events during a worker's lifetime (for example, sending an interrupt signal) addprocs(manager::FooManager) requires FooManager to implement: function launch(manager::FooManager :interrupt when interrupt(workers) is called. The ClusterManager should signal the ap- propriate worker with an interrupt signal. • with :finalize for cleanup purposes.CHAPTER 26. MULTI-PROCESSING AND

you're writing a digital filtering algorithm and you have a method that handles the edges of the signal by applying padding: function myfilter(A, kernel, ::Replicate) Apadded = replicate_edges(A, size(kernel)) which is called at various events during a worker's lifetime (for example, sending an interrupt signal) addprocs(manager::FooManager) requires FooManager to implement: function launch(manager::FooManager :interrupt when interrupt(workers) is called. The ClusterManager should signal the ap- propriate worker with an interrupt signal. • with :finalize for cleanup purposes.CHAPTER 26. MULTI-PROCESSING AND

you're writing a digital filtering algorithm and you have a method that handles the edges of the signal by applying padding: function myfilter(A, kernel, ::Replicate) Apadded = replicate_edges(A, size(kernel)) which is called at various events during a worker's lifetime (for example, sending an interrupt signal) addprocs(manager::FooManager) requires FooManager to implement: function launch(manager::FooManager :interrupt when interrupt(workers) is called. The ClusterManager should signal the ap- propriate worker with an interrupt signal. • with :finalize for cleanup purposes.CHAPTER 26. MULTI-PROCESSING AND

you're writing a digital filtering algorithm and you have a method that handles the edges of the signal by applying padding: function myfilter(A, kernel, ::Replicate) Apadded = replicate_edges(A, size(kernel)) which is called at various events during a worker's lifetime (for example, sending an interrupt signal) addprocs(manager::FooManager) requires FooManager to implement: function launch(manager::FooManager :interrupt when interrupt(workers) is called. The ClusterManager should signal the ap- propriate worker with an interrupt signal. • with :finalize for cleanup purposes.CHAPTER 26. MULTI-PROCESSING AND

you're writing a digital filtering algorithm and you have a method that handles the edges of the signal by applying padding: function myfilter(A, kernel, ::Replicate) Apadded = replicate_edges(A, size(kernel)) which is called at various events during a worker's lifetime (for example, sending an interrupt signal) addprocs(manager::FooManager) requires FooManager to implement: function launch(manager::FooManager :interrupt when interrupt(workers) is called. The ClusterManager should signal the ap- propriate worker with an interrupt signal. • with :finalize for cleanup purposes.CHAPTER 26. MULTI-PROCESSING AND

you're writing a digital filtering algorithm and you have a method that handles the edges of the signal by applying padding: function myfilter(A, kernel, ::Replicate) Apadded = replicate_edges(A, size(kernel)) which is called at various events during a worker's lifetime (for example, sending an interrupt signal) addprocs(manager::FooManager) requires FooManager to implement: function launch(manager::FooManager :interrupt when interrupt(workers) is called. The ClusterManager should signal the ap- propriate worker with an interrupt signal. • with :finalize for cleanup purposes.CHAPTER 26. MULTI-PROCESSING AND