Page 238 - 6734
P. 238
http://192.168.1.33:8787
from dask.distributed import Client, as_completed
import time
def f(x): # функція, яка буде виконуватись в окремих
процесах
time.sleep(x)
return x
if __name__ == '__main__':
#client = Client() # клієнт (кластер на локальній
машині)
client = Client('192.168.1.33:8786') # клієнт
print client
a=client.submit(f, 4) # виконати на кластері
f(x=4)
b=client.submit(f, 2)
c=client.submit(f, 3)
d=client.submit(f, 1)
# для кожного об'єкта Future, що виконує f
for fut in as_completed([a,b,c,d]):
print fut.result(), # отримати результати
асинхронно
#futures=client.map(f, [1,2,3,4,5,6,7,8]) # або
#print client.gather(futures) # чекати усі
результати
# або [fut.result() for fut in futures]
<Client: scheduler='tcp://192.168.1.33:8786'
processes=8 cores=8>
1, 2, 3, 4
PyQt4 – фреймворк Qt в Python
PyQt4 (http://www.riverbankcomputing.com /software /pyqt) – це
“прив’язка” фреймворку Qt до мови Python [45]. Qt – це
багатоплатформовий програмний фреймворк для створення ПЗ
237
