cs and machine files | Python Fiddle

#Control_service.py
        
class requestObj(object):    
    def __init__(self, name, request):
        self.name = name    
        self.cmd = request
    def report_sending(self):
        print ' in %s SENDINNG' % (self.name)
    def report_recieved(self):
        print ' in %s RECEIVED' % (self.name)

def control_service_d(q1,q2):
    while True:
        obj = q1.get(block=True) #get request from client
        obj.report_recieved()
        #process request..
        obj = requestObj('REQUEST')
        q2.put(obj)
        obj.report_sending()
        time.sleep(1) 
        obj = q2.get(block=True) # get request from machine
        
###################################################################################

#Machine.py

class responseObj(object):    
    def __init__(self, name, result):
        self.name = name
        self.result = result
    def report_sending(self):
        print ' in %s SENDINNG' % (self.name)
    def report_recieved(self):
        print ' in %s RECEIVED' % (self.name)

def machine_d(q2):
    while True:
        obj = q2.get(block=True) # get request from CS
        obj.report_recieved()
        #process request..
        obj = responseObj('RESPONSE')
        q2.put(obj)
        obj.report_sending()
        time.sleep(1)
        
        
###################################################################################

#Main.py

import control_service
import machine

if __name__ == '__main__':
    
    Control_service.control_service_d(q1, q2 )
    Machine.machine_d(q1)
    time.sleep(6)
    q1.put(requestObj('ravit')

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()      
        
        
    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()

Python Fiddle

Python Cloud IDE