#!/usr/bin/env python
# coding: utf-8

# # Load balanced map and parallel function decorator

# In[1]:


from __future__ import print_function
from IPython.parallel import Client


# In[2]:


rc = Client()
v = rc.load_balanced_view()


# In[3]:


result = v.map(lambda x: 2*x, range(10))
print("Simple, default map: ", list(result))


# In[4]:


ar = v.map_async(lambda x: 2*x, range(10))
print("Submitted tasks, got ids: ", ar.msg_ids)
result = ar.get()
print("Using a mapper: ", result)


# In[5]:


@v.parallel(block=True)
def f(x): return 2*x

result = f.map(range(10))
print("Using a parallel function: ", result)


# In[ ]: