add threading support test

main.py

@@ -2,14 +2,32 @@ from  pygitlog.gitoperation import *
 from  pygitlog.mdoperation import *
 from pygitlog.example_module import example_function
 import sys
+import threading
+from time import time
+
+def list_of_groups(init_list, childern_list_len):
+    '''
+    init_list为初始化的列表,childern_list_len初始化列表中的几个数据组成一个小列表
+    :param init_list:
+    :param childern_list_len:
+    :return:
+    '''
+    list_of_group = zip(*(iter(init_list),) *childern_list_len)
+    end_list = [list(i) for i in list_of_group]
+    count = len(init_list) % childern_list_len
+    end_list.append(init_list[-count:]) if count !=0 else end_list
+    return end_list
 
 if __name__=="__main__":
     example_function()
     #"""
     ###v5.10后的euler社区修改
     source = "euler"
-    version_new = "f04289acdae57aa4066adee541dadd70b062ac88"
-    version_old = "2c85ebc57b3e1817b6ce1a6b703928e113a90442"
+    #version_new = "f04289acdae5"
+    version_new = "9ffcbab21847"
+    #version_old = "2c85ebc57b3e1817b6ce1a6b703928e113a90442"
+    #version_old = "40a06eb91ba8"
+    version_old = "2c85ebc57b3e"
     """
     ###v5.10前的upstream社区修改
     source = "upstream"
@@ -22,15 +40,38 @@ if __name__=="__main__":
         repopath = "/home/qiurui/Documents/kernel/stable-linux/linux"
     else:
         print("请输入正确的代码来源")
-        sys.exit()
+        sys.exit(0)
     file_name = initmd(version_new,version_old,source)
     #print(file_name)  
     get_repo(repopath) 
-    count = get_commits_commit_count(version_old,version_new)
+    print("总计数量为:")
+    get_commits_commit_count(version_old,version_new)
     hash_list = get_commit_hash(version_old,version_new)
-    a = 0
+    n = len(hash_list) / 10
+    new_hash_list = list_of_groups(hash_list,int(n))
+    start_time = time()
+    threads = []
+    threadLock = threading.Lock()
+    for i in range(0,len(new_hash_list)):
+        for hash in new_hash_list[i]:
+            thread = threading.Thread(target=add_commit_info_threads, args=[threadLock,file_name,hash,hash_list])
+            thread.start()
+            threads.append(thread)
+        for t in threads:
+            t.join()
+    """
+    threads = []
     for hash in hash_list:
-        print(hash)
-        a = a + 1
-        print(a)
+
         add_commit_info(file_name,hash)
+        
+        thread = threading.Thread(target=add_commit_info_threads, args=[thread_lock,file_name,hash,hash_list])
+        thread.start()
+        threads.append(thread)
+        
+    for t in threads:
+        t.join()
+    """
+        
+    print(f"用时{time() - start_time}秒")
+    sys.exit(0)