| |
|
开发:
C++知识库
Java知识库
JavaScript
Python
PHP知识库
人工智能
区块链
大数据
移动开发
嵌入式
开发工具
数据结构与算法
开发测试
游戏开发
网络协议
系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程 数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁 |
-> 区块链 -> A股中的level1跟Level2有什么区别 -> 正文阅读 |
|
[区块链]A股中的level1跟Level2有什么区别 |
A股中的level1跟Level2究竟有什么区别呢?L2行情市场是上海证券交易所推出的实时市场信息收费服务产品,主要提供在上海证券交易所上市交易的证券产品的实时交易数据。包括十档行情,买卖队列,逐笔成交,委托总量和加权价格等多种新式数据。
l2-push-python: python level2行情接入示例 # 推送逐笔成交行情数据 def tick_record_stream(): ????StreamResult = Stub.NewTickRecordStream(entity_pb2.Void()) ????# 用For循环就可以不断消费数据 ????for Result in StreamResult: ????????print(Result) # 推送逐笔委托行情数据 def order_record_stream(): ????StreamResult = Stub.NewOrderRecordStream(entity_pb2.Void()) ????# 用For循环就可以不断消费数据 ????for Result in StreamResult: ????????print(Result) # 推送委托队列行情数据 def order_queue_record_stream(): ????StreamResult = Stub.NewOrderQueueRecordStream(entity_pb2.Void()) ????# 用For循环就可以不断消费数据 ????for Result in StreamResult: ????????print(Result) # 推送股票十档行情行情数据 def stock_quote_record_stream(): ????StreamResult = Stub.NewStockQuoteRecordStream(entity_pb2.Void()) ????# 用For循环就可以不断消费数据 ????for Result in StreamResult: ????????print(Result) if __name__ == '__main__': ????# 可以使用多线程并发接收推送数据 ????ThreadOne = threading.Thread(target=tick_record_stream) ????ThreadTwo = threading.Thread(target=order_record_stream) ????ThreadThree = threading.Thread(target=order_queue_record_stream) ????ThreadFour = threading.Thread(target=stock_quote_record_stream) ????# 多进程并发接收推送数据 ????# ProcessOne = Process(target=tick_record_stream) ????# ProcessTwo = Process(target=order_record_stream) ????# ProcessThree = Process(target=order_queue_record_stream) ????# ProcessFour = Process(target=stock_quote_record_stream) ????# 这设置为随主线程退出子线程,避免产生孤儿或僵尸线程 ????ThreadOne.daemon = True ????ThreadTwo.daemon = True ????ThreadThree.daemon = True ????ThreadFour.daemon = True ????# ProcessOne.daemon = True ????# ProcessTwo.daemon = True ????# ProcessThree.daemon = True ????# ProcessFour.daemon = True ????# 有一点值得注意一下,假如订阅的股票相对活跃,推送的数据就不会有休眠的状态出现,因为Python的GIL锁,所以用多线程接收推送效率不显著,这个时候可以考虑用多进程来接收推送 ????ThreadOne.start() ????ThreadTwo.start() ????ThreadThree.start() ????ThreadFour.start() ????# ProcessOne.start() ????# ProcessTwo.start() ????# ProcessThree.start() ????# ProcessFour.start() ????ThreadOne.join() ????ThreadTwo.join() ????ThreadThree.join() ????ThreadFour.join() ????# ProcessOne.join() ????# ProcessTwo.join() ????# ProcessThree.join() ????# ProcessFour.join() |
|
|
上一篇文章 下一篇文章 查看所有文章 |
|
开发:
C++知识库
Java知识库
JavaScript
Python
PHP知识库
人工智能
区块链
大数据
移动开发
嵌入式
开发工具
数据结构与算法
开发测试
游戏开发
网络协议
系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程 数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁 |
360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 | -2024/11/25 20:55:46- |
|
网站联系: qq:121756557 email:121756557@qq.com IT数码 |