import ctypes
|
import logging
|
import mmap
|
import contextlib
|
import multiprocessing
|
import struct
|
import time
|
from multiprocessing import Process, Value, Array
|
import msgpack
|
|
from huaxin_client import l2_data_manager
|
|
|
def run_process_1(arr: Array):
|
while True:
|
try:
|
time_ = time.time()
|
lenth_count = 5
|
raw_data = arr.get_obj()
|
data_lenth = int(bytes(raw_data[:lenth_count]).decode('utf-8'))
|
data = raw_data[lenth_count:data_lenth + lenth_count]
|
data = msgpack.unpackb(bytes(data))
|
print("解码时间", time.time() - time_)
|
if data:
|
print("数据长度", len(data))
|
except Exception as e:
|
logging.exception(e)
|
time.sleep(1)
|
|
|
def run_process_2(arr: Array):
|
data = [('000990', 7.52, 400, 93000030, 2012, 380422, 380421, 375477, '1')]
|
for i in range(0, 100):
|
data.append(data[0])
|
time_ = time.time()
|
str_ = msgpack.packb(data)
|
print("编码时间", time.time() - time_)
|
print("数据长度", len(str_))
|
lenth_count = 5
|
str_lenth = "{0:0>5}".format(len(str_))
|
lenth_bytes = str_lenth.encode('utf-8')
|
arr[0:lenth_count] = lenth_bytes
|
arr[lenth_count:len(str_) + lenth_count] = str_
|
|
|
###########################测试List#####################################
|
def update_value(_shared_list):
|
while True:
|
_shared_list.append([123, "123123", "54677"])
|
time.sleep(1)
|
|
|
def read_value(_shared_list):
|
while True:
|
print(_shared_list)
|
time.sleep(1)
|
|
|
def test_manager():
|
manager = multiprocessing.Manager()
|
# 使用管理器对象创建一个共享列表
|
shared_list = manager.list()
|
p1 = multiprocessing.Process(target=update_value, args=(shared_list,))
|
p2 = multiprocessing.Process(target=read_value, args=(shared_list,))
|
p1.start()
|
p2.start()
|
while True:
|
time.sleep(2)
|
|
|
if __name__ == '__main__':
|
arr = Array('i', 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)
|
# test_manager()
|
