def METHOD_NAME(self):
    with self._lock:
        correlation_ids = list(self._futures.keys())
        for correlation_id in correlation_ids:
            self._futures[correlation_id].timer_stop()
            del self._futures[correlation_id]