Aluode/PerceptionLabPortable

1 2import numpy as np3 4import pyqtgraph as pg5import pyqtgraph.multiprocess as mp6 7print("\n=================\nStart Process")8proc = mp.Process()9import os10 11print("parent:", os.getpid(), "child:", proc.proc.pid)12print("started")13rnp = proc._import('numpy')14arr = rnp.array([1,2,3,4])15print(repr(arr))16print(str(arr))17print("return value:", repr(arr.mean(_returnType='value')))18print( "return proxy:", repr(arr.mean(_returnType='proxy')))19print( "return auto: ", repr(arr.mean(_returnType='auto')))20proc.join()21print( "process finished")22 23 24 25print( "\n=================\nStart ForkedProcess")26proc = mp.ForkedProcess()27rnp = proc._import('numpy')28arr = rnp.array([1,2,3,4])29print( repr(arr))30print( str(arr))31print( repr(arr.mean()))32proc.join()33print( "process finished")34 35 36 37 38import pyqtgraph as pg39 40app = pg.mkQApp("Multiprocess Example")41 42print( "\n=================\nStart QtProcess")43import sys44 45if (sys.flags.interactive != 1):46    print( "   (not interactive; remote process will exit immediately.)")47proc = mp.QtProcess()48d1 = proc.transfer(np.random.normal(size=1000))49d2 = proc.transfer(np.random.normal(size=1000))50rpg = proc._import('pyqtgraph')51plt = rpg.plot(d1+d2)52