import sys
from pip._vendor.distlib.compat import raw_input
Zero = [" *** ",
" * * ",
"* *",
"* *",
"* *",
" * * ",
" *** "]
One = [" * ", "** ", " * ", " * ", " * ", " * ", "***"]
Two = [" *** ", "* *", "* * ", " * ", " * ", "* ", "*****"]
Three = [" *** ", "* *", " *", " ** ", " *", "* *", " *** "]
Four = [" * ", " ** ", " * * ", "* * ", "******", " * ",
" * "]
Five = ["*****", "* ", "* ", " *** ", " *", "* *", " *** "]
Six = [" *** ", "* ", "* ", "**** ", "* *", "* *", " *** "]
Seven = ["*****", " *", " * ", " * ", " * ", "* ", "* "]
Eight = [" *** ", "* *", "* *", " *** ", "* *", "* *", " *** "]
Nine = [" ****", "* *", "* *", " ****", " *", " *", " *"]
Digits = [Zero, One, Two, Three, Four, Five, Six, Seven, Eight, Nine]
try:
digits = raw_input("Введите число\n") # Заменяем передачу аргумента при запуске на введение пользователем
row = 0
while row < 7:
line = ""
column = 0
while column < len(digits):
number = int(digits[column])
digit = Digits[number]
line += digit[row] + " "
column += 1
print(line)
row += 1
except IndexError:
print("usage: bigdigits.py <number>")
except ValueError as err:
print(err, "in", digits)
import threading
import time
import inspect
class Thread(threading.Thread):
def __init__(self, t, *args):
threading.Thread.__init__(self, target=t, args=args)
self.start()
count = 0
lock = threading.Lock()
def incre():
global count
caller = inspect.getouterframes(inspect.currentframe())[1][3]
print "Inside %s()" % caller
print "Acquiring lock"
with lock:
print "Lock Acquired"
count += 1
time.sleep(2)
def bye():
while count < 5:
incre()
def hello_there():
while count < 5:
incre()
def main():
hello = Thread(hello_there)
goodbye = Thread(bye)
if __name__ == '__main__':
main()
import requests
from multiprocessing.dummy import Pool as ThreadPool
urls = [
'http://www.python.org',
'http://www.python.org/about/',
'http://www.onlamp.com/pub/a/python/2003/04/17/metaclasses.html',
]
def my_get_url(url):
result = requests.get(url)
return result
# Делаем thread pool и указываем количество потоков
pool = ThreadPool(4)
# Запускаем функцию my_get_url в несколько потоков на списке urls и складываем все результаты в список results
results = pool.map(my_get_url, urls)
#ждем завершения всех потоков
pool.close()
pool.join()
from pprint import pprint
import requests
data = requests.get("http://dailybloggz.com/tfy/andreeva_secrets/")
pprint(data.content.decode('utf-8'))
from multiprocessing.dummy import Pool as ThreadPool
from pprint import pprint
import requests
pattern = 'http://www.astateoftrance.com/episodes/episode-'
start_url = 700
urls_list = []
def gen_urls(start):
for i in range(start, 800):
url = pattern + str(i) + '/'
urls_list.append(url)
def my_url_get(url):
result = requests.get(url)
print("{url} was Downloaded".format(url=url))
return result
gen_urls(start_url)
pprint(urls_list)
pool = ThreadPool(20)
results = pool.map(my_url_get, urls_list)
pool.close()
pool.join()
pprint(results[0].content.decode('utf-8'))
try:
bot.polling(none_stop=True, interval=0)
except Exception:
pass
pool = Pool(processes=5)
import urllib2
from multiprocessing.dummy import Pool as ThreadPool
urls = [
'http://www.python.org',
'http://www.python.org/about/',
'http://www.onlamp.com/pub/a/python/2003/04/17/metaclasses.html',
'http://www.python.org/doc/',
'http://www.python.org/download/',
'http://www.python.org/getit/',
'http://www.python.org/community/',
'https://wiki.python.org/moin/',
'http://planet.python.org/',
'https://wiki.python.org/moin/LocalUserGroups',
'http://www.python.org/psf/',
'http://docs.python.org/devguide/',
'http://www.python.org/community/awards/'
# etc..
]
# Пул из 10 потоков
pool = ThreadPool(10)
# Запускаем функцию urlopen в 10 потоков
# на массиве urls
results = pool.map(urllib2.urlopen, urls)
#Ждём завершения всех потоков
pool.close()
pool.join()