from SimpleXMLRPCServer import SimpleXMLRPCServer
def add(a , b): 
  return a+bserver = SimpleXMLRPCServer(("10.249.192.38", 8000))#這里不要用localhost，否則只有本機(jī)才能訪(fǎng)問(wèn)
server.register_function(add)
server.serve_forever()

from xmlrpclib import Server
Proxyserver = ServerProxy("http://localhost:8000")
try: ret = server.add(30,90) print 'result:', ret print 'result type:', type(ret)
except
 Exception, e: print "exception",e

#encoding=utf-8
import sys
import os
import time
import pdb
import httplib
import thread
import threading
constant_p = 0 #創(chuàng)建全局變量，進(jìn)程數(shù)
constant_s = 0 #創(chuàng)建全局變量，線(xiàn)程數(shù)
mutex_g = threading.RLock() #創(chuàng)建全局鎖
def run(count):#該函數(shù)創(chuàng)建3個(gè)線(xiàn)程，同時(shí)調(diào)用3個(gè)不同的函數(shù)
  a = 1
  b = 0
  thread.start_new_thread(test0,(a,b))#這里傳入的參數(shù)需要以元組的形式，跟void指針其實(shí)也差不多
  thread.start_new_thread(test1,(a,b))
  thread.start_new_thread(test2,(a,b))
def test0(a,b):
  global mutex_g
  global constant_s
  threadid = thread.get_ident()
  mutex_g.acquire()#這里需要把線(xiàn)程數(shù)說(shuō)鎖起來(lái)，否則結(jié)果會(huì)被修改
  constant_s = constant_s+1
  mutex_g.release()
  print "thread 0 called,and the threadid is:%d"%(threadid)
  sys.exit(0)
def test1(a,b):
  global mutex_g
  global constant_s
  threadid = thread.get_ident()
  mutex_g.acquire()
  constant_s = constant_s+1
  mutex_g.release()
  print "thread 1 called,and the threadid is:%d"%(threadid)
  sys.exit(0)
def test2(a,b):
  global mutex_g
  global constant_s
  threadid = thread.get_ident()
  mutex_g.acquire()
  constant_s = constant_s+1
  mutex_g.release()
  print "thread 2 called,and the threadid is:%d"%(threadid)
  sys.exit(0)
def my_fork():
  global constant_p
  pid = os.fork()#fork一個(gè)子進(jìn)程，子進(jìn)程的pid=0同時(shí)2個(gè)進(jìn)程會(huì)執(zhí)行my_fork()函數(shù)
  if (pid == 0):#子進(jìn)程執(zhí)行到這個(gè)if里面
    constant_p = constant_s + 1
    run(3)
    time.sleep(5)
    print "total thread is %d"%constant_s#這個(gè)結(jié)果是3，因?yàn)樽舆M(jìn)程創(chuàng)建按了3個(gè)線(xiàn)程
  elif (pid >0):#父進(jìn)程執(zhí)行到這個(gè)if里面
    constant_p = constant_s + 1 run(4)
    time.sleep(5)
    print "total thread is %d"%constant_s#這個(gè)結(jié)果也是3，因?yàn)樵撨M(jìn)程也創(chuàng)建了3個(gè)線(xiàn)程
  else:
    print "fork error"
    sys.exit(0)
  print "total process is %d"%constant_p#該結(jié)果是1,因?yàn)?個(gè)進(jìn)程只執(zhí)行了一次
  constant_p = constant_s + 1
  sys.exit(0)
if __name__ == "__main__":
  my_fork()
  #my_fork()
  #my_fork()