ipc example | Python Fiddle

#import webapp2
import multiprocessing
import time
import sys
from compiler.pyassem import Block

class responseObj(object):    
    def __init__(self, name):
        self.name = name    
    def do_something(self):
        proc_name = multiprocessing.current_process().name
        print ' in %s SENDINNG  %s ' % (proc_name, self.name)
        
        
class requestObj(object):    
    def __init__(self, name):
        self.name = name    
    def do_something(self):
        proc_name = multiprocessing.current_process().name
        print ' in %s SENDINNG  %s ' % (proc_name, self.name)

def control_service_func(q):
    p = multiprocessing.current_process()
    print 'Starting:', p.name, p.pid
    sys.stdout.flush()
    time.sleep(5)   #getting command from client  
    req = requestObj('REQUEST');    
    q.put(req)  #send command to machine
    req.do_something()
    time.sleep(2)       
    q.get(block=True)  
    print 'Exiting :', p.name, p.pid
    sys.stdout.flush()

def machine_func(q):
    p = multiprocessing.current_process()
    print 'Starting:', p.name, p.pid
    sys.stdout.flush()
    while (1):
        obj = q.get(block=True)
        res = responseObj('RESPONSE')     
        q.put(res)
        res.do_something()
        time.sleep(3)        
    print 'Exiting :', p.name, p.pid
    sys.stdout.flush()
    
    
#class MainPage(webapp2.RequestHandler):
#    def get(self):
#        self.response.headers['Content-Type'] = 'text/plain'
#        self.response.write('Hello, World!')

if __name__ == '__main__':

#    application = webapp2.WSGIApplication([('/', MainPage),], debug=True)
    
    queue = multiprocessing.Queue() 
  
    cs = multiprocessing.Process(name='control_service', target=control_service_func, args=(queue,))
    cs.daemon = True

m = multiprocessing.Process(name='machine', target=machine_func, args=(queue,))
    m.daemon = True
 
    cs.start()
    m.start()

queue.close()  
    cs.join()

Python Fiddle

Python Cloud IDE