@classmethod
def _thread_init(cls):
    """Ensure thread local is initialized."""
    if not hasattr(cls._local, '_in_order_futures'):
        cls._local._in_order_futures = set()
        cls._local._activated = False
