使用stock_basic从tushare获取股票数据,从中提取股票代码,用此股票代码下载股票交易数据,打印总股票数量,下载花费时间,使用两个线程来下载,发送两个信号股票的总共的下载进度,

时间: 2023-10-09 07:08:52 浏览: 32
以下是代码实现: ```python import tushare as ts import time import threading import signal # 信号量,用于记录下载进度 total_progress = 0 finished_progress = 0 # 处理 Ctrl+C 退出信号 def signal_handler(sig, frame): print("Download process stopped.") exit(0) # 从 tushare 获取所有股票代码 stock_list = ts.get_stock_basics().index.tolist() # 定义线程类 class DownloadThread(threading.Thread): def __init__(self, thread_id, stock_codes): threading.Thread.__init__(self) self.thread_id = thread_id self.stock_codes = stock_codes def run(self): global finished_progress start_time = time.time() for stock_code in self.stock_codes: # 从 tushare 下载股票数据 df = ts.get_hist_data(stock_code) if df is not None: # 统计下载进度 finished_progress += 1 # 打印下载进度 print("Thread %d: Download progress %.2f%%" % (self.thread_id, finished_progress / total_progress * 100)) end_time = time.time() print("Thread %d finished, time cost: %.2f seconds" % (self.thread_id, end_time - start_time)) # 处理信号 signal.signal(signal.SIGINT, signal_handler) # 记录股票数量 total_progress = len(stock_list) # 创建两个线程,分别下载股票数据 thread1 = DownloadThread(1, stock_list[:len(stock_list)//2]) thread2 = DownloadThread(2, stock_list[len(stock_list)//2:]) # 启动线程 thread1.start() thread2.start() # 等待线程结束 thread1.join() thread2.join() print("Total stocks downloaded: %d" % finished_progress) ``` 该程序首先从 tushare 中获取所有股票代码,然后创建两个线程来下载股票数据。每个线程负责下载一部分股票数据,并记录下载进度。程序还使用信号量来处理 Ctrl+C 退出信号,以便在退出程序时清理资源。最后输出总共下载的股票数量。

相关推荐

最新推荐

recommend-type

Python爬取股票信息,并可视化数据的示例

截止2019年年底我国股票投资者数量为15975.24万户, 如此多的股民热衷于炒股,首先抛开炒股技术不说, 那么多股票数据是不是非常难找, 找到之后是不是看着密密麻麻的数据是不是头都大了? 今天带大家爬取雪球平台的股票...
recommend-type

ADSP-BF533的例程源码29:FIR信号处理源码

ADSP-BF533的例程源码29:FIR信号处理源码
recommend-type

风险管理模板.png

风险管理模板.png
recommend-type

长玻纤增强聚丙烯市场:规模增长、竞争格局与未来机遇.pdf

QYResearch是全球知名的大型咨询公司,行业涵盖各高科技行业产业链细分市场,横跨如半导体产业链(半导体设备及零部件、半导体材料、集成电路、制造、封测、分立器件、传感器、光电器件)、光伏产业链(设备、硅料/硅片、电池片、组件、辅料支架、逆变器、电站终端)、新能源汽车产业链(动力电池及材料、电驱电控、汽车半导体/电子、整车、充电桩)、通信产业链(通信系统设备、终端设备、电子元器件、射频前端、光模块、4G/5G/6G、宽带、IoT、数字经济、AI)、先进材料产业链(金属材料、高分子材料、陶瓷材料、纳米材料等)、机械制造产业链(数控机床、工程机械、电气机械、3C自动化、工业机器人、激光、工控、无人机)、食品药品、医疗器械、农业等。 邮箱:market@qyresearch.com
recommend-type

2024-“她经济”洞察报告-QuestMobile-41页

2024-“她经济”洞察报告-QuestMobile-41页
recommend-type

中文翻译Introduction to Linear Algebra, 5th Edition 2.1节

中文翻译Introduction to Linear Algebra, 5th Edition 2.1节 线性代数的核心问题是求解方程组。这些方程都是线性的,即未知数仅与数相乘——我们绝不会 遇见 x 乘以 y。我们的第一个线性方程组较小。接下来你来看看它引申出多远: 两个方程 两个未知数 x − 2y = 1 3x + 2y = 11 (1) 我们一次从一个行开始。第一个方程 x − 2y = 1 得出了 xy 平面的一条直线。由于点 x = 1, y = 0 解 出该方程,因此它在这条直线上。因为 3 − 2 = 1,所以点 x = 3, y = 1 也在这条直线上。若我们选择 x = 101,那我们求出 y = 50。 这条特定直线的斜率是 12,是因为当 x 变化 2 时 y 增加 1。斜率在微积分中很重要,然而这是线 性代数! 图 2.1 将展示第一条直线 x − 2y = 1。此“行图”中的第二条直线来自第二个方程 3x + 2y = 11。你 不能错过两条线的交点 x = 3, y = 1。点 (3, 1) 位于两条线上并且解出两个方程。
recommend-type

管理建模和仿真的文件

管理Boualem Benatallah引用此版本:布阿利姆·贝纳塔拉。管理建模和仿真。约瑟夫-傅立叶大学-格勒诺布尔第一大学,1996年。法语。NNT:电话:00345357HAL ID:电话:00345357https://theses.hal.science/tel-003453572008年12月9日提交HAL是一个多学科的开放存取档案馆,用于存放和传播科学研究论文,无论它们是否被公开。论文可以来自法国或国外的教学和研究机构,也可以来自公共或私人研究中心。L’archive ouverte pluridisciplinaire
recommend-type

识别MATLAB微分方程求解中的混沌行为:分析非线性方程混沌行为的实用技巧

![matlab求解微分方程](https://img-blog.csdnimg.cn/2021062810300367.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTQ3OTY3OA==,size_16,color_FFFFFF,t_70) # 1. MATLAB微分方程求解概述 微分方程是描述物理、工程和金融等领域中动态系统的数学模型。MATLAB提供了强大的工具来求解微分方程,包括内置求解器和自定义函数
recommend-type

physon如何做ERP系统

作为一个AI语言模型,我可以给您提供一些基本的建议和思路: 1.明确需求和目标:在开始开发ERP系统之前,需要明确您的业务需求和目标,了解您的业务流程、流程数据、员工角色和权限、财务管理等方面的要求,这样才能更好的设计和开发ERP系统。 2.选择技术框架和开发工具:选择合适的技术框架和开发工具是ERP系统开发的关键。选择一种流行的技术框架和工具可以提高开发效率和质量。 3.设计数据库:ERP系统需要一个功能强大的数据库来存储数据。设计数据库需要考虑数据的完整性、安全性和可扩展性。 4.设计系统架构:系统架构是ERP系统的骨架,需要考虑系统的可扩展性、可维护性和性能。 5.开发和测试:
recommend-type

zigbee-cluster-library-specification

最新的zigbee-cluster-library-specification说明文档。