import ctypes
|
import mmap
|
import contextlib
|
import multiprocessing
|
import time
|
from multiprocessing import Process, Value, Array
|
|
from huaxin_client import l2_data_manager
|
|
|
def run_process_1(arr:Array):
|
while True:
|
data_lenth = arr[0]
|
data = bytes(arr[1:data_lenth+1]).decode('utf-8')
|
if data:
|
print(eval(data))
|
time.sleep(1)
|
|
|
def run_process_2(arr:Array):
|
str_=b"['000333',13.89]"
|
arr[0] = len(str_)
|
arr[1:len(str_)+1] = str_
|
|
|
if __name__ == '__main__':
|
arr = Array(ctypes.c_byte, range(1024*1024))
|
p1, p2 = multiprocessing.Pipe()
|
serverProcess = multiprocessing.Process(target=run_process_1, args=(arr,))
|
jueJinProcess = multiprocessing.Process(target=run_process_2, args=(arr,))
|
serverProcess.start()
|
jueJinProcess.start()
|
|
while True:
|
time.sleep(2)
|
