home *** CD-ROM | disk | FTP | other *** search
/ OS/2 Shareware BBS: 10 Tools / 10-Tools.zip / fnd101.zip / Add-Ons / Fnorb / examples / threaded / client.py next >
Encoding:
Python Source  |  1999-06-28  |  3.8 KB  |  144 lines
  1. #!/usr/bin/env python
  2. #############################################################################
  3. # Copyright (C) DSTC Pty Ltd (ACN 052 372 577) 1997
  4. # All Rights Reserved.
  5. #
  6. # The software contained on this media is the property of the DSTC Pty
  7. # Ltd.  Use of this software is strictly in accordance with the
  8. # license agreement in the accompanying LICENSE.HTML file.  If your
  9. # distribution of this software does not contain a LICENSE.HTML file
  10. # then you have no rights to use this software in any manner and
  11. # should contact DSTC at the address below to determine an appropriate
  12. # licensing arrangement.
  13. # 
  14. #      DSTC Pty Ltd
  15. #      Level 7, Gehrmann Labs
  16. #      University of Queensland
  17. #      St Lucia, 4072
  18. #      Australia
  19. #      Tel: +61 7 3365 4310
  20. #      Fax: +61 7 3365 4311
  21. #      Email: enquiries@dstc.edu.au
  22. # 
  23. # This software is being provided "AS IS" without warranty of any
  24. # kind.  In no event shall DSTC Pty Ltd be liable for damage of any
  25. # kind arising out of or in connection with the use or performance of
  26. # this software.
  27. #
  28. # Project:      Distributed Environment
  29. # File:         $Source: /units/arch/src/Fnorb/examples/threaded/RCS/client.py,v $
  30. # Version:      @(#)$RCSfile: client.py,v $ $Revision: 1.1 $
  31. #
  32. #############################################################################
  33. """ Client for the multi-threaded example. """
  34.  
  35.  
  36. # Standard/built-in modules.
  37. import sys, time, thread
  38.  
  39. # Fnorb modules.
  40. from Fnorb.orb import CORBA
  41.  
  42. # Stubs generated by 'fnidl'.
  43. import HelloWorld
  44.  
  45.  
  46. class Client:
  47.  
  48.     def __init__(self, server, num_threads):
  49.     """ Constructor. """
  50.  
  51.     self.__server = server
  52.     self.__num_threads = num_threads
  53.     self.__lk = thread.allocate_lock()
  54.  
  55.     return
  56.  
  57.     def start(self):
  58.     """ Start the threads. """
  59.  
  60.     for i in range(self.__num_threads):
  61.         thread.start_new_thread(self.__worker_thread, (i,))
  62.  
  63.     return
  64.  
  65.     def wait(self):
  66.     """ Wait for all threads to complete. """
  67.  
  68.     self.__lk.acquire()
  69.     num_threads = self.__num_threads
  70.     self.__lk.release()
  71.  
  72.     while num_threads > 0:
  73.         time.sleep(2)
  74.  
  75.         self.__lk.acquire()
  76.         num_threads = self.__num_threads
  77.         self.__lk.release()
  78.  
  79.     return
  80.  
  81.     #########################################################################
  82.     # Private interface.
  83.     #########################################################################
  84.  
  85.     def __worker_thread(self, thread_no):
  86.     """ Worker thread. """
  87.  
  88.     print 'Thread:', thread_no, 'Started...'
  89.  
  90.     # Payload!
  91.     payload = '\0' * 16000
  92.  
  93.     # Time 100 calls!
  94.     start = time.time()
  95.     for i in range(100):
  96.         self.__server.hello_world(payload)
  97.     end = time.time()
  98.  
  99.     print 'Thread:', thread_no, 'Time taken:', end - start
  100.  
  101.     self.__lk.acquire()
  102.     self.__num_threads = self.__num_threads - 1
  103.     self.__lk.release()
  104.  
  105.     thread.exit()
  106.  
  107.  
  108. def main(argv):
  109.     """ Do it! """
  110.  
  111.     print 'Initialising the ORB...'
  112.  
  113.     # Initialise the ORB.
  114.     orb = CORBA.ORB_init(argv, CORBA.ORB_ID)
  115.  
  116.     # Read the server's stringified IOR from a file (this is just a 'cheap and
  117.     # cheerful' way of locating the server - in practise the client would use
  118.     # the naming or trader services).
  119.     stringified_ior = open('server.ref', 'r').read()
  120.  
  121.     # Convert the stringified IOR into an active object reference.
  122.     server = orb.string_to_object(stringified_ior)
  123.  
  124.     # Create a client with 10 threads!
  125.     client = Client(server, 10)
  126.  
  127.     # Start the threads.
  128.     client.start()
  129.  
  130.     # Wait for them all to complete.
  131.     client.wait()
  132.  
  133.     print 'All threads complete!'
  134.  
  135.     return 0
  136.     
  137. #############################################################################
  138.  
  139. if __name__ == '__main__':
  140.     # Do it!
  141.     sys.exit(main(sys.argv))
  142.  
  143. #############################################################################
  144.