Как создать новый поток python с классами?

Question

На основе компонента SMTPD я написал собственный SMTP-сервер с авторизацией и т. Д. Последнее, что мне нужно сделать, это добавить синтаксический анализ сообщений в новый поток, когда он появится.

Таким образом, мой компонент состоит из двух классов: SMTPServer и SMTPChannel. Он отлично работает в одном потоке, как это:

def handle_accept(self): 
    pair = self.accept() 

    if pair is not None: 
     conn, addr = pair 

     logging.info('Incoming connection from ' + str(addr)) 

     channel = SMTPChannel(config, conn, addr) 

Вход выглядеть следующим образом:

kiril@kiril-X501A1 ~/www/py_email $ python SMTPServer.py 
[2015-05-27 11:15:57] [MainThread] INFO: Server started at 192.168.0.103:1026 
[2015-05-27 11:16:46] [MainThread] INFO: Incoming connection from ('192.168.0.46', 52423) 
[2015-05-27 11:16:46] [MainThread] DEBUG: <-- '220 SMTP Server 0.1 ESMTP' 
[2015-05-27 11:16:46] [MainThread] DEBUG: --> EHLO : '*******' 
[2015-05-27 11:16:46] [MainThread] DEBUG: <-- '250-SMTP Server 0.1 ESMTP Hello *******\n250-SIZE 20480000\n250 AUTH PLAIN LOGIN CRAM-MD5' 
[2015-05-27 11:16:47] [MainThread] DEBUG: --> AUTH : 'PLAIN AGFkbWluADEyMzQ=' 
[2015-05-27 11:16:47] [MainThread] INFO: ('192.168.0.46', 52423) successfully authenticated 
[2015-05-27 11:16:47] [MainThread] DEBUG: <-- '235 Authentication successful.' 
[2015-05-27 11:16:47] [MainThread] DEBUG: --> MAIL : 'FROM:<reply@*******>' 
[2015-05-27 11:16:47] [MainThread] DEBUG: <-- '250 Ok' 
[2015-05-27 11:16:47] [MainThread] DEBUG: --> RCPT : 'TO:<destination@*******>' 
[2015-05-27 11:16:47] [MainThread] DEBUG: <-- '250 Ok' 
[2015-05-27 11:16:47] [MainThread] DEBUG: --> DATA 
[2015-05-27 11:16:47] [MainThread] DEBUG: <-- '354 End data with <CR><LF>.<CR><LF>' 
[2015-05-27 11:16:47] [MainThread] DEBUG: <-- '250 Ok' 
[2015-05-27 11:16:47] [MainThread] DEBUG: --> QUIT 
[2015-05-27 11:16:47] [MainThread] DEBUG: <-- '221 Bye' 
[2015-05-27 11:16:47] [MainThread] INFO: Incoming connection from ('192.168.0.46', 52422) 
[2015-05-27 11:16:47] [MainThread] DEBUG: <-- '220 SMTP Server 0.1 ESMTP' 
[2015-05-27 11:16:47] [MainThread] DEBUG: --> EHLO : '*******' 
[2015-05-27 11:16:47] [MainThread] DEBUG: <-- '250-SMTP Server 0.1 ESMTP Hello *******\n250-SIZE 20480000\n250 AUTH PLAIN LOGIN CRAM-MD5' 
[2015-05-27 11:16:48] [MainThread] DEBUG: --> AUTH : 'PLAIN AGFkbWluADEyMzQ=' 
[2015-05-27 11:16:48] [MainThread] INFO: ('192.168.0.46', 52422) successfully authenticated 
[2015-05-27 11:16:48] [MainThread] DEBUG: <-- '235 Authentication successful.' 
[2015-05-27 11:16:48] [MainThread] DEBUG: --> MAIL : 'FROM:<reply@*******>' 
[2015-05-27 11:16:48] [MainThread] DEBUG: <-- '250 Ok' 
[2015-05-27 11:16:48] [MainThread] DEBUG: --> RCPT : 'TO:<destination@*******>' 
[2015-05-27 11:16:48] [MainThread] DEBUG: <-- '250 Ok' 
[2015-05-27 11:16:48] [MainThread] DEBUG: --> DATA 
[2015-05-27 11:16:48] [MainThread] DEBUG: <-- '354 End data with <CR><LF>.<CR><LF>' 
[2015-05-27 11:16:48] [MainThread] DEBUG: <-- '250 Ok' 
[2015-05-27 11:16:48] [MainThread] DEBUG: --> QUIT 
[2015-05-27 11:16:48] [MainThread] DEBUG: <-- '221 Bye' 

Но когда я добавляю темы, как это:

def handle_accept(self): 
    pair = self.accept() 

    if pair is not None: 
     conn, addr = pair 

     logging.info('Incoming connection from ' + str(addr)) 

     new_thread = threading.Thread(target=SMTPChannel, args=(config, conn, addr,)) 
     new_thread.start() 

Журнал выглядит следующим образом:

kiril@kiril-X501A1 ~/www/py_email $ python SMTPServer.py 
[2015-05-27 11:23:29] [MainThread] INFO: Server started at 192.168.0.103:1026 
[2015-05-27 11:23:49] [MainThread] INFO: Incoming connection from ('192.168.0.46', 52414) 
[2015-05-27 11:23:49] [Thread-1 ] DEBUG: <-- '220 SMTP Server 0.1 ESMTP' 
[2015-05-27 11:23:49] [MainThread] DEBUG: --> EHLO : '*****' 
[2015-05-27 11:23:49] [MainThread] DEBUG: <-- '250-SMTP Server 0.1 ESMTP Hello ********\n250-SIZE 20480000\n250 AUTH PLAIN LOGIN CRAM-MD5' 
[2015-05-27 11:23:49] [MainThread] DEBUG: --> AUTH : 'PLAIN AGFkbWluADEyMzQ=' 
[2015-05-27 11:23:49] [MainThread] INFO: ('192.168.0.46', 52414) successfully authenticated 

Как вы можете видеть Thread-1 пожаров только один раз, то все сообщения возвращаются к основной теме ... Может быть, есть что-то, чтобы иметь дело с классом, простирающимся в class MerlinSMTPServer(asyncore.dispatcher): и class SMTPChannel(asynchat.async_chat):

Answer 1

Вы не можете смешивать asyncore и темы, как это. Весь смысл приложения asyncore/asynchat заключается в том, что существует цикл событий вокруг select, который обрабатывает все ваши сокеты и совершает вызовы для различных обработчиков. Все это происходит в одном потоке. См. Введение в документацию asyncore, в которой объясняется это.

Запуск нового asynchat канала на другой поток не приносит пользы. Это означает, что он регистрируется в цикле событий из другого потока. (На самом деле это не потокобезопасно, поэтому вам просто повезло, если он работает.) После этого цикл событий и диспетчеризация обработчикам канала происходят в основном потоке.

Если вы хотите использовать многопоточность, не используйте asyncore. Если вы хотите использовать asyncore, не используйте многопоточность.