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

testing threading

imanay - - Load All Authors

File last commit:

r122:123


                r159:160

Download file

             test1.py
        
                    21 lines
            
             | 524 B
            
                | text/x-python
            
             |
                PythonLexer
            
             / trunk / absroot / source / abspy / test / threading / test1.py
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      import Queue

      import threading

      def basic_worker(queue):

          while True:

              item = queue.get()

              # do_work(item)

              print(item)

              queue.task_done()

      def basic():

          # http://docs.python.org/library/queue.html

          queue = Queue.Queue()

          for i in range(3):

               t = threading.Thread(target=basic_worker,args=(queue,))

               t.daemon = True

               t.start()

          for item in range(4):

              queue.put(item)

          queue.join()       # block until all tasks are done

          print('got here')

      basic()

	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

				import Queue
				import threading

				def basic_worker(queue):
				while True:
				item = queue.get()
				# do_work(item)
				print(item)
				queue.task_done()
				def basic():
				# http://docs.python.org/library/queue.html
				queue = Queue.Queue()
				for i in range(3):
				t = threading.Thread(target=basic_worker,args=(queue,))
				t.daemon = True
				t.start()
				for item in range(4):
				queue.put(item)
				queue.join() # block until all tasks are done
				print('got here')

				basic()