ABS/abscontrol Files · trunk/absroot/source/abspy/test/threading/test8.py

First beam is loaded by default after sending the beam file to the control modules.

imanay - - Load All Authors

File last commit:

r159:160


                r231:232

Download file

             test8.py
        
                    43 lines
            
             | 1.0 KiB
            
                | text/x-python
            
             |
                PythonLexer
            
             / trunk / absroot / source / abspy / test / threading / test8.py
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      #!/usr/bin/env python

      import Queue

      import threading

      import urllib2

      import time

      hosts = ["http://yahoo.com", "http://google.com", "http://amazon.com",

               "http://ibm.com", "http://apple.com"]

      queue = Queue.Queue()

      class ThreadUrl(threading.Thread):

          """Threaded Url Grab"""

          def __init__(self, queue):

              threading.Thread.__init__(self)

              self.queue = queue

          def run(self):

            while True:

              #grabs host from queue

              host = self.queue.get()

              #grabs urls of hosts and prints first 1024 bytes of page

              url = urllib2.urlopen(host)

              print url.read(1024)

              #signals to queue job is done

              self.queue.task_done()

      start = time.time()

      def main():

          #spawn a pool of threads, and pass them queue instance 

          for i in range(5):

              t = ThreadUrl(queue)

              t.setDaemon(True)

              t.start()

         #populate queue with data   

              for host in hosts:

                  queue.put(host)

          queue.join()

      main()

      print "Elapsed Time: %s" % (time.time() - start)

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

				#!/usr/bin/env python
				import Queue
				import threading
				import urllib2
				import time

				hosts = ["http://yahoo.com", "http://google.com", "http://amazon.com",
				"http://ibm.com", "http://apple.com"]

				queue = Queue.Queue()

				class ThreadUrl(threading.Thread):
				"""Threaded Url Grab"""
				def __init__(self, queue):
				threading.Thread.__init__(self)
				self.queue = queue

				def run(self):
				while True:
				#grabs host from queue
				host = self.queue.get()

				#grabs urls of hosts and prints first 1024 bytes of page
				url = urllib2.urlopen(host)
				print url.read(1024)

				#signals to queue job is done
				self.queue.task_done()

				start = time.time()

				def main():
				#spawn a pool of threads, and pass them queue instance
				for i in range(5):
				t = ThreadUrl(queue)
				t.setDaemon(True)
				t.start()
				#populate queue with data
				for host in hosts:
				queue.put(host)
				queue.join()

				main()
				print "Elapsed Time: %s" % (time.time() - start)