#!/usr/bin/env python
# coding: utf-8

import pyjsonrpc
from time import sleep
import multiprocessing

#將結果通過PIPE傳送給主程序
def work(pipe , a , b ) :
    i = 0
    while True :
        i += 1 ;
        if i > 1000000000 :
            break
    pipe.send(a + b)



class RequestHandler(pyjsonrpc.HttpRequestHandler)
 
:

    @pyjsonrpc.rpcmethod
    def add(self, a, b):
        #多程序中一對一的通訊工具，不同於QUEUE
        pipe = multiprocessing.Pipe()
        #print pipe

        # Pass an end of the pipe to process 1
        #將業務邏輯推到另一個程序中處理
        p1   = multiprocessing.Process(target=work, args=(pipe[0],a , b))
        p1.start()
        #等待子程序返回
 

        p1.join()
        #返回子程序發回來的結果
        return pipe[1].recv()        

# Threading HTTP-Server
http_server = pyjsonrpc.ThreadingHttpServer(
    server_address = ('192.168.56.100', 8080),
    RequestHandlerClass = RequestHandler
)
print "Starting HTTP server ..."
print "URL: http://localhost:8080"
http_server.serve_forever()