加载中…python多进程-多线程-内部实现的协程
(2024-07-08 14:22:03)
标签：
python进程线程协程 |
分类： 接口类的哈 |
既然 外层 进行多股票 多指标的 并发过程：
那为什么 策略算法的内部还要进行股票 传统的list股票遍历的 ：
策略算法内层 进行多股票，
刚有疑问，大牛就直接甩了连接呵呵呵呵。原来有个不知道的常识嘎嘎 “
协程：”
不是传统的list股票遍历的 做法：而是自行开启 协程。
https://blog.csdn.net/qq_69218005/article/details/129789977
嘎嘎其实大牛应该语音上直接提醒了几遍，知识面涵盖不到，不知道啥玩意。 没摔脸上连接压根拿金句也没当干粮，才继续问嘎嘎
才被艾特的甩脸上嘎嘎
并发：外层 多进程-多线程-内部实现的协程。
其他也可以的参考呵呵呵呵呵哒
https://www.zhihu.com/question/642116682/answer/3382223270
https://blog.csdn.net/weixin_45786770/article/details/114651721
https://blog.csdn.net/YZL40514131/article/details/125629232
https://www.bilibili.com/video/BV1Lr421t73K/?p=5&spm_id_from=pageDriver&vd_source=2a756a841699e678985ce674ad996db8
第6分钟附近
import
asyncio async
def calculate(stock_info, *args,
**kwargs): print(f"Processing stock
{stock_info['code']}
with args
{args} and kwargs
{kwargs}") await
asyncio.sleep(1) return
f"Processed
{stock_info['code']}"
async
def main(): stock_info_all = [ {"code": "600000.SH.GG", "stock_type": "GG"},
{"code": "600001.SH.GG", "stock_type": "GG"},
{"code": "600002.SH.GG", "stock_type": "GG"},
{"code": "600003.SH.GG", "stock_type": "GG"}
] # 示例额外参数
args = (1, 2)
kwargs = {'additional': 'parameters'} # 创建协程任务列表
tasks = [calculate(stock_info, *args, **kwargs)
for stock_info in stock_info_all] results = await
asyncio.gather(*tasks) for result in results: print(result) asyncio.run(main())
代码中：
async def calculate(stock_info, *args,
**kwargs):
的函数实现，是自己和没有开启协程时候的一样的
云云云，吓唬云，也一样可以return一个结果
喜欢
0
赠金笔