def METHOD_NAME(self):
    with self._lock:
        correlation_ids = [
            correlation_id
            for correlation_id, future
            in self._futures.items()
            if future.is_expired()
        ]
        for correlation_id in correlation_ids:
            self._futures[correlation_id].timer_stop()
            del self._futures[correlation_id]