Использование win32com с многопоточностью

Я работаю над веб-приложением с CherryPy, которому требуется доступ к нескольким приложениям через COM.

Прямо сейчас я создаю новый экземпляр приложения с каждым запросом, что означает, что каждый запрос ждет 3 секунды для запуска приложения и 0,01 для фактического задания.

Я хотел бы запустить каждое COM-приложение один раз, сохранить его и повторно использовать в течение нескольких секунд для следующих запросов, потому что большую часть времени оно используется пакетом из 5-10 запросов ajax, а затем ничем в течение нескольких часов.

Можно ли совместно использовать COM-объект для всех потоков приложения CherryPy?

Вот краткое изложение нескольких экспериментов, которые показывают, как он работает сейчас для каждого запроса и как он не работает между потоками.

Следующий код успешно запускает и останавливает Excel:

>>> import pythoncom, win32com.client
>>> def start():
    global xl
    xl = win32com.client.Dispatch('Excel.Application')

>>> def stop():
    global xl
    xl.quit()
    xl = None

>>> start()
>>> stop()

Но следующий код запускает Excel и закрывает его через 3 секунды.

>>> import pythoncom, win32com.client, threading, time
>>> def start():
    global xl
    pythoncom.CoInitialize()
    xl = win32com.client.Dispatch('Excel.Application')
    time.sleep(3)

>>> threading.Thread(target=start).start()

Я добавил звонок CoInitialize() в противном случае xl объект не будет работать (см. этот пост).

И я добавил 3-секундную паузу, чтобы я мог видеть в диспетчере задач, что процесс EXCEL.EXE запускается и остается активным в течение 3 секунд.

Почему он умирает после того, как поток, который начал это, заканчивается?

Я проверил документацию CoInitialize(), но я не мог понять, возможно ли заставить его работать в многопоточной среде.

Источник

3 ответа

Решение

Если вы хотите использовать win32com в нескольких потоках, вам нужно сделать немного больше работы, так как COMObject не может быть передан в поток напрямую. Вам нужно использовать CoMarshalInterThreadInterfaceInStream() а также CoGetInterfaceAndReleaseStream() передать экземпляр между потоками:

import pythoncom, win32com.client, threading, time

def start():
    # Initialize
    pythoncom.CoInitialize()

    # Get instance
    xl = win32com.client.Dispatch('Excel.Application')

    # Create id
    xl_id = pythoncom.CoMarshalInterThreadInterfaceInStream(pythoncom.IID_IDispatch, xl)

    # Pass the id to the new thread
    thread = threading.Thread(target=run_in_thread, kwargs={'xl_id': xl_id})
    thread.start()

    # Wait for child to finish
    thread.join()

def run_in_thread(xl_id):
    # Initialize
    pythoncom.CoInitialize()

    # Get instance from the id
    xl = win32com.client.Dispatch(
            pythoncom.CoGetInterfaceAndReleaseStream(xl_id, pythoncom.IID_IDispatch)
    )
    time.sleep(5)


if __name__ == '__main__':
    start()

Для получения дополнительной информации см.: https://mail.python.org/pipermail/python-win32/2008-June/007788.html

Источник

Ответ от @Mauriusz Jamro был действительно полезен. Просто чтобы добавить к этому, также убедитесь, что вы делаете:

      pythoncom.CoUninitialize ()

в конце, чтобы не было утечки памяти. Вы можете вызвать его где-нибудь после использования CoInitialize() и до завершения вашего процесса.

PS- У меня не хватило репутации, чтобы прокомментировать его ответ, поэтому пришлось прибегнуть к написанию нового ответа. Ваше здоровье!

Источник

Попробуйте использовать многопроцессорность. Сработал у меня после долгих поисков.

from multiprocessing import Process

p = Process(target=test, args=())
p.start()
p.join()
Источник
Другие вопросы по тегам