這篇文章主要介紹了Python統計時間內的併發數程式碼例項,文中通過示例程式碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下

Python實現併發的手段：

1、作業系統提供：程序、執行緒；

2、程式語言提供：協程：使用者空間的排程（py3）；

# coding:utf-8

# 1.匯入模組
# datatime模組用於定義時間及時間的加減操作
# MySQLdb模組用於Python2.0連線資料庫，Python3.0連線資料庫使用pymysql
# xlwt模組是excel操作模組，用於將資料寫入excel中

import datetime
import MySQLdb
import xlwt

# 2.連線資料庫，獲取資料
# MySQLdb.connect用於定義連線資料庫的屬性
# myconn.cursor()定義遊標物件
# query_sql定義查詢的語句
# mycursor.execute()執行查詢語句，僅僅是執行語句，不輸出結果。
# mycursor.fetchall()提取查詢資料。all全部資料，one單條資料，many取多少條資料。fetchmany(10)取10條資料。
# mycursor.close()關閉遊標
# myconn.close()關閉連線

myconn = MySQLdb.connect(host='1',user='wn',passwd='9eu',db='bs',charset='utf8')
mycursor = myconn.cursor()
query_sql = '''
select JOIN_TIME,LEAVE_TIME from commfee where JOIN_TIME between '2019-12-24 15:00:00' and '2019-12-24 15:30:00' 
'''

mycursor.execute(query_sql)
sql_result = mycursor.fetchall()
mycursor.close()
myconn.close()

# 3.定義全域性引數
# sum1 = []定義列表sum1,sum1用於生成比較的時間列表
# sum2 = []定義列表sum2,sum2用於生成併發數的列表

sum1 = []
sum2 = []

# 4.定義資料篩選函式
# compare_time 比較時間，最開始值取開始時間的第一個值。
# start_time = [sql_result[i][0] for i in range(0,len(sql_result))]將查詢到的結果拆分為兩個列表start_time和end_time。
# compare_time < start_time[len(sql_result)-1]，compare_time時間和start_time列表中的時間比較
# compare_time += datetime.timedelta(seconds=1)，每次比較後，compare_time時間+1
# datetime.timedelta(seconds=1)，timedelta(seconds=1)時間變化1s
# sum1.append(compare_time),將得到的compare_time寫入sum1列表中。

def query_data():
  compare_time = sql_result[0][0]
  start_time = [sql_result[i][0] for i in range(0,len(sql_result))]   
  end_time = [sql_result[i][1] for i in range(0,len(sql_result))]
  while compare_time < start_time[len(sql_result)-1]:
     compare_time += datetime.timedelta(seconds=1)     
     count1 = 0     
     count2 = 0
     for time1 in start_time:      
       if time1 <= compare_time:         
         count1 = count1 + 1         
     for time2 in end_time:              
       if time2 <= compare_time:          
         count2 = count2 - 1         
     sum1.append(compare_time)     
     sum2.append(count1+count2)

# 5.定義excel操作函式
# xlwt.Workbook(encoding='utf-8')定義編碼格式
# wbk.add_sheet('My worksheet')定義操作的sheet表
# xlwt.XFStyle()定義單元格格式
# datastyle.num_format_str = 'yyyy-mm-dd hh:mm:ss'定義單元格中資料格式
# worksheet.write(row,sum1[row],datastyle) 按定義的格式寫入資料
# wbk.save()儲存操作的excel表格。

def re_sheet():      
  wbk = xlwt.Workbook(encoding='utf-8')
  worksheet = wbk.add_sheet('My worksheet')
  datastyle = xlwt.XFStyle()
  datastyle.num_format_str = 'yyyy-mm-dd hh:mm:ss'
  for row in range(0,len(sum1)):    
     worksheet.write(row,datastyle)     
     worksheet.write(row,1,sum2[row])     
  wbk.save('Concurrency.xls')  
query_data()   
re_sheet()

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支援我們。