#上证代码
shanghaicode = []
for i in range(600000, 604000, 1):
  shanghaicode.append(str(i))
#深证代码
shenzhencode = []
for i in range(1000000, 1005000, 1):
  i = str(i)[1:] 
  shenzhencode.append(i)

def getalldata(code):
    if os.path.exists(datapath + code + '.csv'):
      print(code + 'already existed!')
      return
    metadata = broker.get_stock_pro(code)
    if len(metadata) == 0:
      return
    metadata.to_csv('C:/Users/abc/Desktop/' + code + '.csv',index = False)
    print(code + 'finished!')

from concurrent.futures.thread import ThreadPoolExecutor #多线程

  executor = ThreadPoolExecutor(max_workers=3)
  for datatemp in executor.map(getalldata, shenzhencode):
    pass 
  executor = ThreadPoolExecutor(max_workers=3)
  for datatemp in executor.map(getalldata, shanghaicode):
    pass