Pfthb

I am trying to build a COM server to get real time information. The problem is that all other functionalities stop while localserver is opened. The rest of the code just runs when the localserver is closed.

I have searched for solutions and failed trying multiprocessing, not because this wouldn't work, I guess because I suck. Anyway, I am stuck in this part.

import pythoncom
import win32com
from win32com.server import localserver
from multiprocessing import Process

class PythonUtilities(object):

 _reg_clsid_ = 'D9C54599-9011-4678-B1EB-A07FD272F0AF'
 _reg_desc_ = "Change information between programs"
 _reg_progid_ = "Python.LetsTalk"
 _public_attrs_ = ['speech', 'roger']
 _readonly_attrs_ = ['roger']
 _public_methods_ = ['talktome']

 def __init__(self):
 self.roger = 'roger'
 self.speech = None

 def talktome(self,speech):
 self.speech = speech
 print ('New speech received: ' + self.speech)
 return self.roger

### ___ ###

def runserver(mess):
 print(mess)
 localserver.serve(['D9C54599-9011-4678-B1EB-A07FD272F0AF'])

if __name__=='__main__':

 pu = PythonUtilities

 print ("Registering COM Server ")
 win32com.server.register.UseCommandLine(pu)

 # Fine so far.
 # The problem starts here:

 localserver.serve(['D9C54599-9011-4678-B1EB-A07FD272F0AF'])

 #... rest of the code waiting for localserver be closed

 # Experiment... Doesnt work:
 #proc = Process(target=runserver, args = ('starting process',))
 #proc.start()
 #proc.join()

It's important to say that all messages sent from the client seem to be correctly displayed BUT ONLY AFTER I close the local server manually. I want to receive it in real time like a chat app. I mean, I want to keep the localserver opened and being able to work with the information received along the rest of the code.

My problem was solved rewriting the localserver.serve() function and starting it in a new thread as the code below.

import pythoncom
from win32com.client import Dispatch # to get attributes
from win32com.server import register, factory
from threading import Thread
from queue import Queue

class PythonUtilities(object):

 _reg_clsid_ = 'D9C54599-9011-4678-B1EB-A07FD272F0AF'
 _reg_desc_ = "Change information between programs"
 _reg_progid_ = "Python.LetsTalk"
 _public_attrs_ = ['speech']
 _public_methods_ = ['talktome']

 queue_speech = Queue()

 def talktome(self,speech):
 self.queue_speech.put(speech)
 print ('New speech received: ' + speech)
 return 'roger'

### ___ ###

# use instead localserver.serve()
def runserver():

 # added - multithread support
 pythoncom.CoInitialize()

 clsids = ['D9C54599-9011-4678-B1EB-A07FD272F0AF']

 infos = factory.RegisterClassFactories(clsids)

 # commented - from original localserver.serve() method
 #pythoncom.EnableQuitMessage(win32api.GetCurrentThreadId()) 

 pythoncom.CoResumeClassObjects()

 pythoncom.PumpMessages()

 factory.RevokeClassFactories( infos )

 pythoncom.CoUninitialize()

 if __name__=='__main__':

 #use this
 server_thread = Thread(target=runserver) # Process works as well
 server_thread.start()

 #instead this 
 #localserver.serve(['D9C54599-9011-4678-B1EB-A07FD272F0AF'])

 #... rest of the code now works in parallel

Also I have made some improvements like Queue to get data later. I hope it can help others.