Board logo

标题: Python3使用多线程/线程锁 [打印本页]
作者: admin    时间: 2019-9-28 10:10     标题: Python3使用多线程/线程锁

例子一：（函数+多线程）
  1. #coding=utf-8
  3. import _thread #导入多线程模块
  5. from time import sleep #导入sleep()函数
  7. from datetime import datetime #导入datetime模块
  8. date_time_format = '%Y-%m-%d %H:%M:%S' #自定义时间的输出格式
  10. def date_time_str(date_time): #自定义转换时间格式的函数
  11. return datetime.strftime(date_time, date_time_format)
  13. def func1():
  14. print('+++线程一的开始时间:', date_time_str(datetime.now()))
  15. print('+++线程一休眠4秒')
  16. sleep(4)
  17. print('+++线程一的结束时间:', date_time_str(datetime.now()))
  19. def func2():
  20. print('***线程二的开始时间:', date_time_str(datetime.now()))
  21. print('***线程二休眠2秒')
  22. sleep(2)
  23. print('***线程二的结束时间:', date_time_str(datetime.now()))
  25. def func_main():
  26. print('——————进程的开始时间:', date_time_str(datetime.now()))
  27. print('——————所有线程的统一开始时间:', date_time_str(datetime.now()))
  29. _thread.start_new_thread(func1,()) #执行线程一
  30. _thread.start_new_thread(func2,()) #执行线程二
  32. sleep(3) #进程休眠3秒后继续执行
  33. print('——————进程的结束时间:', date_time_str(datetime.now()))
  34. print('——————所有线程的强制结束时间:', date_time_str(datetime.now()))
  36. if __name__ == '__main__':
  38. func_main()
复制代码
脚本运行的效果： C:\Users\jacky\Desktop>python xx.py ——————进程的开始时间: 2019-02-16 11:02:52 ——————所有线程的统一开始时间: 2019-02-16 11:02:52 +++线程一的开始时间: 2019-02-16 11:02:52 ***线程二的开始时间: 2019-02-16 11:02:52 +++线程一休眠4秒 ***线程二休眠2秒 ***线程二的结束时间: 2019-02-16 11:02:54 ——————进程的结束时间: 2019-02-16 11:02:55 ——————所有线程的强制结束时间: 2019-02-16 11:02:55 C:\Users\jacky\Desktop> ## 备注：所有线程的开始时间都是一样的；所有线程都会在进程执行结束后，立即强制结束。 ###### 例子二：（函数+多线程）
  1. #coding=utf-8
  3. import _thread
  5. from time import sleep
  7. from datetime import datetime
  8. date_time_format = '%Y-%m-%d %H:%M:%S'
  10. def date_time_str(date_time):
  11. return datetime.strftime(date_time, date_time_format)
  13. def func1():
  14. print('+++线程一的开始时间:', date_time_str(datetime.now()))
  15. print('+++线程一休眠4秒')
  16. sleep(4)
  17. print('+++线程一的结束时间:', date_time_str(datetime.now()))
  19. def func2():
  20. print('***线程二的开始时间:', date_time_str(datetime.now()))
  21. print('***线程二休眠2秒')
  22. sleep(2)
  23. print('***线程二的结束时间:', date_time_str(datetime.now()))
  25. def func_main():
  26. print('——————进程的开始时间:', date_time_str(datetime.now()))
  27. print('——————所有线程的统一开始时间:', date_time_str(datetime.now()))
  29. _thread.start_new_thread(func1,()) #执行线程一
  30. _thread.start_new_thread(func2,()) #执行线程二
  32. sleep(4) #进程休眠4秒后继续执行
  33. print('——————进程的结束时间:', date_time_str(datetime.now()))
  34. print('——————所有线程的强制结束时间:', date_time_str(datetime.now()))
  36. if __name__ == '__main__':
  38. func_main()
复制代码
脚本运行的效果： C:\Users\jacky\Desktop>python xx.py ——————进程的开始时间: 2019-02-16 11:07:35 ——————所有线程的统一开始时间: 2019-02-16 11:07:35 +++线程一的开始时间: 2019-02-16 11:07:35 ***线程二的开始时间: 2019-02-16 11:07:35 ***线程二休眠2秒 +++线程一休眠4秒 ***线程二的结束时间: 2019-02-16 11:07:37 +++线程一的结束时间: 2019-02-16 11:07:39 ——————进程的结束时间: 2019-02-16 11:07:39 ——————所有线程的强制结束时间: 2019-02-16 11:07:39 C:\Users\jacky\Desktop> ###### 例子三：（函数+多线程）
  1. #coding=utf-8
  3. import _thread
  5. from time import sleep
  7. from datetime import datetime
  8. date_time_format = '%Y-%m-%d %H:%M:%S'
  10. def date_time_str(date_time):
  11. return datetime.strftime(date_time, date_time_format)
  13. def func1():
  14. print('+++线程一的开始时间:', date_time_str(datetime.now()))
  15. print('+++线程一休眠4秒')
  16. sleep(4)
  17. print('+++线程一的结束时间:', date_time_str(datetime.now()))
  19. def func2():
  20. print('***线程二的开始时间:', date_time_str(datetime.now()))
  21. print('***线程二休眠2秒')
  22. sleep(2)
  23. print('***线程二的结束时间:', date_time_str(datetime.now()))
  25. def func_main():
  26. print('——————进程的开始时间:', date_time_str(datetime.now()))
  27. print('——————所有线程的统一开始时间:', date_time_str(datetime.now()))
  29. _thread.start_new_thread(func1,()) #执行线程一
  30. _thread.start_new_thread(func2,()) #执行线程二
  32. sleep(5) #进程休眠5秒后继续执行
  33. print('——————进程的结束时间:', date_time_str(datetime.now()))
  34. print('——————所有线程的强制结束时间:', date_time_str(datetime.now()))
  36. if __name__ == '__main__':
  38. func_main()
复制代码
脚本运行的效果： C:\Users\jacky\Desktop>python xx.py ——————进程的开始时间: 2019-02-16 11:09:37 ——————所有线程的统一开始时间: 2019-02-16 11:09:37 +++线程一的开始时间: 2019-02-16 11:09:37 +++线程一休眠4秒 ***线程二的开始时间: 2019-02-16 11:09:37 ***线程二休眠2秒 ***线程二的结束时间: 2019-02-16 11:09:39 +++线程一的结束时间: 2019-02-16 11:09:41 ——————进程的结束时间: 2019-02-16 11:09:42 ——————所有线程的强制结束时间: 2019-02-16 11:09:42 C:\Users\jacky\Desktop> ###### 例子四：（函数+多线程+线程锁）
  1. #coding=utf-8
  3. import _thread
  4. from time import sleep
  6. from datetime import datetime
  7. date_time_format = '%Y-%m-%d %H:%M:%S'
  9. def date_time_str(date_time):
  10. return datetime.strftime(date_time, date_time_format)
  12. def func1(lock):
  13. print('线程1的开始时间:',date_time_str(datetime.now()), '，休眠（8）秒')
  14. sleep(8)
  15. print('线程1的结束时间:', date_time_str(datetime.now()))
  16. lock.release()
  18. def func2(lock):
  19. print('线程2的开始时间:',date_time_str(datetime.now()), '，休眠（2）秒')
  20. sleep(2)
  21. print('线程2的结束时间:', date_time_str(datetime.now()))
  22. lock.release()
  24. def func3(lock):
  25. print('线程3的开始时间:',date_time_str(datetime.now()), '，休眠（5）秒')
  26. sleep(5)
  27. print('线程3的结束时间:', date_time_str(datetime.now()))
  28. lock.release()
  30. def func_main():
  32. print(f"——————进程的开始时间: {date_time_str(datetime.now())}")
  34. fields_1 = range(0, 3) # "3" 意味着有3个线程，依此类推
  35. fields_2 = []
  37. for Key_1 in fields_1:
  38. Key_1 = _thread.allocate_lock()
  39. Key_1.acquire()
  40. fields_2.append(Key_1)
  42. # [0]、[1]、[2]代表线程号，依此类推；分别给每个函数的一个变量进行赋值
  43. _thread.start_new_thread(func1,(fields_2[0],))
  44. _thread.start_new_thread(func2,(fields_2[1],))
  45. _thread.start_new_thread(func3,(fields_2[2],))
  47. for i in fields_1:
  48. while fields_2[i].locked():
  49. pass
  51. print(f"——————进程的结束时间: {date_time_str(datetime.now())}")
  53. if __name__ == '__main__':
  55. func_main()
复制代码
脚本运行的效果： C:\Users\jacky\Desktop>python xx.py ——————进程的开始时间: 2019-02-16 11:53:58 线程2的开始时间: 2019-02-16 11:53:58 ，休眠（2）秒 线程1的开始时间: 2019-02-16 11:53:58 ，休眠（8）秒 线程3的开始时间: 2019-02-16 11:53:58 ，休眠（5）秒 线程2的结束时间: 2019-02-16 11:54:00 线程3的结束时间: 2019-02-16 11:54:03 线程1的结束时间: 2019-02-16 11:54:06 ——————进程的结束时间: 2019-02-16 11:54:06 C:\Users\jacky\Desktop> ## 备注：所有线程的开始时间都是一样的；使用线程锁时，进程会在所有线程都执行结束后，立即结束。 ###### 例子五：（函数+多线程+线程锁）
  1. #coding=utf-8
  3. import _thread
  4. from time import sleep
  6. from datetime import datetime
  7. date_time_format = '%Y-%m-%d %H:%M:%S'
  9. def date_time_str(date_time):
  10. return datetime.strftime(date_time, date_time_format)
  12. def func1(n_sec, lock):
  13. print('线程1的开始时间:',date_time_str(datetime.now()), '，休眠（', n_sec, '）秒')
  14. sleep(n_sec)
  15. print('线程1的结束时间:', date_time_str(datetime.now()))
  16. lock.release()
  18. def func2(n_sec, lock):
  19. print('线程2的开始时间:',date_time_str(datetime.now()), '，休眠（', n_sec, '）秒')
  20. sleep(n_sec)
  21. print('线程2的结束时间:', date_time_str(datetime.now()))
  22. lock.release()
  24. def func3(n_sec, lock):
  25. print('线程3的开始时间:',date_time_str(datetime.now()), '，休眠（', n_sec, '）秒')
  26. sleep(n_sec)
  27. print('线程3的结束时间:', date_time_str(datetime.now()))
  28. lock.release()
  30. def func4(n_sec, lock):
  31. print('线程4的开始时间:',date_time_str(datetime.now()), '，休眠（', n_sec, '）秒')
  32. sleep(n_sec)
  33. print('线程4的结束时间:', date_time_str(datetime.now()))
  34. lock.release()
  36. def func_main():
  38. print(f"——————进程的开始时间: {date_time_str(datetime.now())}")
  40. fields_1 = range(0, 4) # "4" 意味着有4个线程，依此类推
  41. fields_2 = []
  43. for Key_1 in fields_1:
  44. Key_1 = _thread.allocate_lock()
  45. Key_1.acquire()
  46. fields_2.append(Key_1)
  48. # [0]、[1]、[2]、[3]代表线程号，依此类推；分别给每个函数的两个变量进行赋值
  49. _thread.start_new_thread(func1,(8, fields_2[0]))
  50. _thread.start_new_thread(func2,(2, fields_2[1]))
  51. _thread.start_new_thread(func3,(5, fields_2[2]))
  52. _thread.start_new_thread(func4,(10, fields_2[3]))
  54. for i in fields_1:
  55. while fields_2[i].locked():
  56. pass
  58. print(f"——————进程的结束时间: {date_time_str(datetime.now())}")
  60. if __name__ == '__main__':
  62. func_main()
复制代码
脚本运行的效果： C:\Users\jacky\Desktop>python xx.py ——————进程的开始时间: 2019-02-16 12:02:37 线程1的开始时间: 2019-02-16 12:02:37 ，休眠（ 8 ）秒 线程2的开始时间: 2019-02-16 12:02:37 ，休眠（ 2 ）秒 线程3的开始时间: 2019-02-16 12:02:37 ，休眠（ 5 ）秒 线程4的开始时间: 2019-02-16 12:02:37 ，休眠（ 10 ）秒 线程2的结束时间: 2019-02-16 12:02:39 线程3的结束时间: 2019-02-16 12:02:42 线程1的结束时间: 2019-02-16 12:02:45 线程4的结束时间: 2019-02-16 12:02:47 ——————进程的结束时间: 2019-02-16 12:02:47 C:\Users\jacky\Desktop> ###### 例子六：（类+多线程）
  1. #coding=utf-8
  3. import _thread
  5. from time import sleep
  7. from datetime import datetime
  8. date_time_format = '%Y-%m-%d %H:%M:%S'
  10. def date_time_str(date_time):
  11. return datetime.strftime(date_time, date_time_format)
  13. class class1():
  15. def func1(self):
  16. print('+++线程一的开始时间:', date_time_str(datetime.now()))
  17. print('+++线程一休眠4秒')
  18. sleep(4)
  19. print('+++线程一的结束时间:', date_time_str(datetime.now()))
  21. def func2(self):
  22. print('***线程二的开始时间:', date_time_str(datetime.now()))
  23. print('***线程二休眠2秒')
  24. sleep(2)
  25. print('***线程二的结束时间:', date_time_str(datetime.now()))
  27. def func_main(self):
  28. print('——————进程的开始时间:', date_time_str(datetime.now()))
  29. print('——————所有线程的统一开始时间:', date_time_str(datetime.now()))
  31. _thread.start_new_thread(self.func1,()) #执行线程一
  32. _thread.start_new_thread(self.func2,()) #执行线程二
  34. sleep(5) #进程休眠5秒后继续执行
  35. print('——————进程的结束时间:', date_time_str(datetime.now()))
  36. print('——————所有线程的强制结束时间:', date_time_str(datetime.now()))
  38. if __name__ == '__main__':
  40. myclass = class1()
  41. myclass.func_main()
复制代码
脚本运行的效果： C:\Users\jacky\Desktop>python xx.py ——————进程的开始时间: 2019-02-17 21:31:29 ——————所有线程的统一开始时间: 2019-02-17 21:31:29 +++线程一的开始时间: 2019-02-17 21:31:29 ***线程二的开始时间: 2019-02-17 21:31:29 ***线程二休眠2秒 +++线程一休眠4秒 ***线程二的结束时间: 2019-02-17 21:31:31 +++线程一的结束时间: 2019-02-17 21:31:33 ——————进程的结束时间: 2019-02-17 21:31:34 ——————所有线程的强制结束时间: 2019-02-17 21:31:34 C:\Users\jacky\Desktop> ###### 例子七：（类+多线程+线程锁）
  1. #coding=utf-8
  3. import _thread
  4. from time import sleep
  6. from datetime import datetime
  7. date_time_format = '%Y-%m-%d %H:%M:%S'
  9. def date_time_str(date_time):
  10. return datetime.strftime(date_time, date_time_format)
  12. class class1():
  13. def func1(self,lock):
  14. print('线程1的开始时间:',date_time_str(datetime.now()), '，休眠（8）秒')
  15. sleep(8)
  16. print('线程1的结束时间:', date_time_str(datetime.now()))
  17. lock.release()
  19. def func2(self,lock):
  20. print('线程2的开始时间:',date_time_str(datetime.now()), '，休眠（2）秒')
  21. sleep(2)
  22. print('线程2的结束时间:', date_time_str(datetime.now()))
  23. lock.release()
  25. def func3(self,lock):
  26. print('线程3的开始时间:',date_time_str(datetime.now()), '，休眠（5）秒')
  27. sleep(5)
  28. print('线程3的结束时间:', date_time_str(datetime.now()))
  29. lock.release()
  31. def func_main(self):
  33. print(f"——————进程的开始时间: {date_time_str(datetime.now())}")
  35. fields_1 = range(0, 3)
  36. fields_2 = []
  38. for Key_1 in fields_1:
  39. Key_1 = _thread.allocate_lock()
  40. Key_1.acquire()
  41. fields_2.append(Key_1)
  43. _thread.start_new_thread(self.func1,(fields_2[0],)) #给一个变量进行赋值
  44. _thread.start_new_thread(self.func2,(fields_2[1],))
  45. _thread.start_new_thread(self.func3,(fields_2[2],))
  47. for i in fields_1:
  48. while fields_2[i].locked():
  49. pass
  51. print(f"——————进程的结束时间: {date_time_str(datetime.now())}")
  53. if __name__ == '__main__':
  55. myclass = class1()
  56. myclass.func_main()
复制代码
脚本运行的效果： C:\Users\jacky\Desktop>python xx.py ——————进程的开始时间: 2019-02-17 21:48:59 线程2的开始时间: 2019-02-17 21:48:59 ，休眠（2）秒 线程1的开始时间: 2019-02-17 21:48:59 ，休眠（8）秒 线程3的开始时间: 2019-02-17 21:48:59 ，休眠（5）秒 线程2的结束时间: 2019-02-17 21:49:01 线程3的结束时间: 2019-02-17 21:49:04 线程1的结束时间: 2019-02-17 21:49:07 ——————进程的结束时间: 2019-02-17 21:49:07 C:\Users\jacky\Desktop> ###### 例子八：（类+多线程+线程锁）
  1. #coding=utf-8
  3. import _thread
  4. from time import sleep
  6. from datetime import datetime
  7. date_time_format = '%Y-%m-%d %H:%M:%S'
  9. def date_time_str(date_time):
  10. return datetime.strftime(date_time, date_time_format)
  12. class class1():
  13. def func1(self,n_sec, lock):
  14. print('线程1的开始时间:',date_time_str(datetime.now()), '，休眠（', n_sec, '）秒')
  15. sleep(n_sec)
  16. print('线程1的结束时间:', date_time_str(datetime.now()))
  17. lock.release()
  19. def func2(self,n_sec, lock):
  20. print('线程2的开始时间:',date_time_str(datetime.now()), '，休眠（', n_sec, '）秒')
  21. sleep(n_sec)
  22. print('线程2的结束时间:', date_time_str(datetime.now()))
  23. lock.release()
  25. def func3(self,n_sec, lock):
  26. print('线程3的开始时间:',date_time_str(datetime.now()), '，休眠（', n_sec, '）秒')
  27. sleep(n_sec)
  28. print('线程3的结束时间:', date_time_str(datetime.now()))
  29. lock.release()
  31. def func4(self,n_sec, lock):
  32. print('线程4的开始时间:',date_time_str(datetime.now()), '，休眠（', n_sec, '）秒')
  33. sleep(n_sec)
  34. print('线程4的结束时间:', date_time_str(datetime.now()))
  35. lock.release()
  37. def func_main(self):
  39. print(f"——————进程的开始时间: {date_time_str(datetime.now())}")
  41. fields_1 = range(0, 4)
  42. fields_2 = []
  44. for Key_1 in fields_1:
  45. Key_1 = _thread.allocate_lock()
  46. Key_1.acquire()
  47. fields_2.append(Key_1)
  49. _thread.start_new_thread(self.func1,(8,fields_2[0])) #给两个变量进行赋值
  50. _thread.start_new_thread(self.func2,(2,fields_2[1]))
  51. _thread.start_new_thread(self.func3,(5,fields_2[2]))
  52. _thread.start_new_thread(self.func4,(10,fields_2[3]))
  54. for i in fields_1:
  55. while fields_2[i].locked():
  56. pass
  58. print(f"——————进程的结束时间: {date_time_str(datetime.now())}")
  60. if __name__ == '__main__':
  62. myclass = class1()
  63. myclass.func_main()
复制代码
脚本运行的效果： C:\Users\jacky\Desktop>python xx.py ——————进程的开始时间: 2019-02-17 21:58:23 线程3的开始时间: 2019-02-17 21:58:23 ，休眠（ 5 ）秒 线程2的开始时间: 2019-02-17 21:58:23 ，休眠（ 2 ）秒 线程4的开始时间: 2019-02-17 21:58:23 ，休眠（ 10 ）秒 线程1的开始时间: 2019-02-17 21:58:23 ，休眠（ 8 ）秒 线程2的结束时间: 2019-02-17 21:58:25 线程3的结束时间: 2019-02-17 21:58:28 线程1的结束时间: 2019-02-17 21:58:31 线程4的结束时间: 2019-02-17 21:58:33 ——————进程的结束时间: 2019-02-17 21:58:33 C:\Users\jacky\Desktop> 相关文章： CentOS8使用多线程+Ping



欢迎光临 blog.zhuohua.store (http://blog.zhuohua.store/) Powered by Discuz! 7.2