Почему flask_socketio.disconnect препятствует завершению потока?

# -*- coding: utf-8 -*-
 
import os
import threading
import time
import collections
from datetime import datetime
 
import flask
import flask_socketio
 
def get_unix_time():
    return int(time.mktime(datetime.now().timetuple()))
 
class Stack(collections.deque):
 
    def __init__(self, iterable=(), maxlen=None):
        collections.deque.__init__(self, iterable, maxlen)
 
    @property
    def size(self):
        return len(self)
 
    @property
    def empty(self):
        return self.size == 0
 
    @property
    def head(self):
        return self[-1]
 
    @property
    def tail(self):
        return self[0]
 
    def push(self, x):
        self.append(x)
 
# SERVER
 
app = flask.Flask(__name__)
sio = flask_socketio.SocketIO(app, async_mode='gevent')
 
connector_sid = None
echo_stack = Stack()
 
thread = None
thread_lock = threading.Lock()
 
 
def background_thread(app):
    time.sleep(2)  # delay for normal connection
 
    while True:
        if echo_stack.size >= 5:
            break
        time_ = get_unix_time()
        echo_stack.push(time_)
        sio.emit('echo', time_, namespace='/connector')
        sio.sleep(1)
 
    with app.app_context():
        flask_socketio.disconnect(connector_sid, '/connector')
 
 
@sio.on('connect', namespace='/connector')
def on_connect_connector():
    """Connector connection event handler."""
    global connector_sid, thread
    print 'Attempt to connect a connector {}...'.format(request.sid)
 
    # if the connector is already connected, reject the connection
    if connector_sid is not None:
        print 'Connection for connector {} rejected'.format(request.sid)
        return False
        # raise flask_socketio.ConnectionRefusedError('Connector already connected')
 
    connector_sid = request.sid
    print('Connector {} connected'.format(request.sid))
 
    with thread_lock:
        if thread is None:
            thread = sio.start_background_task(
                background_thread, current_app._get_current_object())
 
    # уведомить клиента, что коннектор подключен
    sio.emit('set_connector_status', True, namespace='/client')
 
 
@sio.on('disconnect', namespace='/connector')
def on_disconnect_connector():
    """Connector disconnect event handler."""
    global connector_sid, thread
 
    print 'start join'
    thread.join()
    print 'end join'
    thread = None
    print 'after disconet:', thread
 
    connector_sid = None
 
    echo_stack.clear()
 
    print('Connector {} disconnect'.format(request.sid))
 
    # уведомить клиент, что коннектор отключен
    sio.emit('set_connector_status', False, namespace='/client')
 
 
@sio.on('echo', namespace='/connector')
def on_echo_connector(time_):
    if not echo_stack.empty:
        if echo_stack.head == time_:
            echo_stack.pop()
 
 
@sio.on('message', namespace='/connector')
def on_message_connector(cnt):
    # print 'Msg: {}'.format(cnt)
    pass
 
if __name__ == '__main__':
    sio.run(app)

# -*- coding: utf-8 -*-
 
import sys
import threading
import time
 
import socketio
import socketio.exceptions
 
sio = socketio.Client()
thread = None
thread_lock = threading.Lock()
work = False
 
 
def background_thread():
    # example task
    cnt = 0
    while work:
        cnt += 1
        if cnt % 10 == 0:
            sio.emit('message', cnt // 10, namespace='/connector')
        sio.sleep(0.1)
 
 
@sio.on('connect', namespace='/connector')
def on_connect():
    """Обработчик события подключенеия к серверу."""
    global thread, work
 
    print '\n-----            Connected to server            -----' \
          '\n----- My SID:  {} -----\n'.format(sio.sid)
 
    work = True  # установить флаг работы
 
    # запустить в потоке цикл опроса Пирамиды
    with thread_lock:
        if thread is None:
            thread = sio.start_background_task(background_thread)
 
 
@sio.on('disconnect', namespace='/connector')
def on_disconnect():
    """Обработчик события отключения от сервера."""
    global thread, work
 
    # сбросить флаг работы, чтобы на след. итерации беск. цикл завершился
    work = False
    thread.join()
    thread = None
 
    # отключиться от сервера
    sio.disconnect()
    print '\n-----         Disconnected from server          -----\n'
 
    # перейти в режим бексонечных попыток подключения к серверу
    main()
 
 
@sio.on('echo', namespace='/connector')
def on_echo(time_):
    sio.emit('echo', time_, namespace='/connector')
 
 
def main():
    while True:
        try:
            sio.connect('http://localhost:5000/connector',
                        namespaces=['/connector'])
            sio.wait()
        except socketio.exceptions.ConnectionError:
            print 'Trying to connect to the server...'
            time.sleep(1)
        except KeyboardInterrupt:
            print '\n---------- EXIT ---------\n'
            sys.exit()
        except Exception as e:
            print e
 
 
if __name__ == '__main__':
    print '\n---------- START CLIENT ----------\n'
    main()