Проект «SnakeProject» Михаила Козлова

⇒ Python ⇐

CISCO

Voice(Asterisk\Cisco)

Microsoft

Powershell

SQL\T-SQL

FreeBSD and Nix

1С

Общая

WEB Разработка

ORACLE SQL \ JAVA

Мото

Стрельба, пневматика, оружие

Python: простой пример работы с процессами и потоками

Очень простой для понимания пример запуска параллельно нескольких потоков.

Простой пример с запуском нескольких потоков одновременно:

import threading import time def proc(n,s): time.sleep(s) print u'Поток', str(n), u'завершился' for x in range(1,4): print u'Поток', str(x), u'стартовал' print u'Количество активных потоков ',threading.activeCount() if(x == 1): threading.Thread(target=proc, args=[x,3]).start() elif(x == 2): threading.Thread(target=proc, args=[x,1]).start() elif(x == 3): threading.Thread(target=proc, args=[x,2]).start()

Конечно функционал модуля threading намного богаче, есть возможность работы с блокировками:

import threading, time res = {'A': threading.Lock(), 'B': threading.Lock()} def proc(n, rs): for r in rs: print u"Процесс", n, u"обращается к ресурсу", r #запрос на запирание замка res[r].acquire() print u"Процесс", n, u"запер ресурс", r time.sleep(4) print u"Процесс", n, u"продолжается" for r in rs: #запрос на отпирание замка res[r].release() print u"Процесс", n, u"завершен" p1 = threading.Thread(target=proc, args=[1, "AB"]) p1.start() time.sleep(2) p2 = threading.Thread(target=proc, args=[2, "BA"]) p2.start()

Модуль Queue имеет три типа очередей, разница заключается в порядоке получаемых значений:

Отдельное спасибо за перевод по этому модулю данной странице: http://john16blog.blogspot.co.il/2012/05/python-queue.html

class Queue.Queue(maxsize)

Очередь типа FIFO (First Input First Output - первым вошел, первым вышел). 

maxsize - параметр типа integer, который устанавливает предел для числа элементов, которые могут быть помещены в очередь. Вставка новых элементов блокируется, как только этот размер был достигнут, до тех пор пока элементы не будут удалены из очереди. Если значение параметра равно или меньше нуля, то очередь будет бесконечной.

class Queue.LifoQueue(maxsize)
Класс реализующий очередь LIFO, или по другому "стэк"(Last Input First Output - последним вошел, первым вышел).

maxsize аналогичен параметру в классе Queue.Queue.

class Queue.PriorityQueue(maxsize)
Класс реализующий очередь с приоритетами. Параметр maxsize аналогичен параметру в классе Queue.Queue. 

Элементы, добавляемые в подобную очередь должны представлять из себя кортеж типа (значение приоритета, данные). Первыми из очереди забираются элементы с меньшим приоритетом, полученным с помощью функции sorted().

И отдельное спасибо за краткую и удобную справку: http://www.py-my.ru/post/4bfb3c691d41c846bc000066#!

Queue.Queue() - отдает значения по принципу "первый пришел - первый ушел"
Queue.LifoQueue() - "последний пришел - первый ушел"
Queue.put(item [ , block [ , timeout]]) - при добавлении значения можно блокировать очередь, что-б не возникало коллизий
Queue.get([ block [ , timeout]]) - при получении значения можно блокировать очередь, что-б одновременной другой поток не выхватил данные, данная ф-ия ждет пока не появятся данные, при истечении тайм аута, если он задан, срабатывает exception
Queue.get_nowait() - взять значение без ожидания, если данных нет то срабатывает exception Queue.Empty

import sys from time import sleep from Queue import Queue from threading import Thread, enumerate # Создаем FIFO очередь q = Queue() #Функция генерирующая данные для очереди def source(n): for i in xrange(1, 1 + n): yield i #Функция заполняющая очередь заданиями def put(n): for item in source(n): q.put(item) def worker(): while True: #Если заданий нет - закончим цикл if q.empty(): sys.exit() # Получаем задание из очереди item = q.get() print u'Очередь: %s выполняется' % item # Сообщаем о выполненном задании q.task_done() print u'Очередь: %s завершилась' % item #Создаем и запускаем потоки, которые будут обслуживать очередь for x in range(1,4): print u'Поток', str(x), u'стартовал' put(x) Thread(target=worker).start() sleep(2) print 'Over'

Комментарии пользователей