Guest User

Untitled

a guest
Dec 11th, 2018
104
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.93 KB | None | 0 0
  1. #!/usr/bin/env python3
  2. import time
  3. import rpyc
  4. from rpyc.utils.server import ThreadedServer
  5. from threading import Thread
  6.  
  7.  
  8. class RPCService(rpyc.Service):
  9.  
  10. def __init__(self,my_object):
  11. self.my_object = my_object
  12.  
  13. def exposed_get_my_object(self):
  14. return self.my_object
  15.  
  16.  
  17. class My_Object(object):
  18.  
  19. def __init__(self):
  20. self.solution = 42
  21.  
  22.  
  23. def execute():
  24.  
  25. my_object = My_Object()
  26.  
  27. server = ThreadedServer(RPCService(my_object),
  28. port=12345,
  29. protocol_config={"allow_all_attrs":True,
  30. "allow_pickle":True,
  31. "allow_setattr":True})
  32. t = Thread(target=server.start)
  33. t.daemon = True
  34. t.start()
  35.  
  36. while True:
  37. print(f"Solution: {my_object.solution}")
  38. time.sleep(2)
  39.  
  40.  
  41.  
  42. if __name__ == "__main__":
  43.  
  44. execute()
Add Comment
Please, Sign In to add comment