平行處理時，不論使用direct view或是loadbalance view, 物件序列化都是一個很麻煩的問題，後來找解法時，發現可以使用
dill處理。
因為只有direct view支援use_dill() function, 如果loadbalace view也要使用dill時，可使用以下方法 (
stackoverflow)。
rc = Client()
rc.direct_view().use_dill()
lv = rc.load_balanced_view()
如果要使用自定義的class時，還要考慮
Data movement via DirectView, 否則無法呼叫class instance method,
class MyObject(object):
def __init__(self, val):
import os
import platform
self.name = platform.node()
self.pid = os.getpid()
self.val = val
def run(self):
return "{}, myobject {}_{}".format(self.val, self.name, self.pid)
def MyObjectrun(val):
obj = MyObject(val)
return obj.run()
def test_parallel():
rc = Client(profile='ssh')
rc.block = True
print "nodes: {}".format(len(rc.ids))
rc.direct_view().use_dill()
rc.direct_view()['MyObject'] = MyObject
lview = rc.load_balanced_view()
res = lview.apply_sync(MyObjectrun, 10)
print res
