linux c++線程池的實現

http://blog.csdn.net/zhoubl668/article/details/8927090?t=1473221020107

線程池的原理大家都知道，直接上代碼了^_^

Thread.h

[cpp]?view plaincopy
  1. #ifndef?__THREAD_H???
  2. #define?__THREAD_H???
  3. ??
  4. #include?<vector>???
  5. #include?<string>???
  6. #include?<pthread.h>???
  7. ??
  8. using?namespace?std;??
  9. ??
  10. /**?
  11. ?*?執行任務的類，設置任務數據并執行?
  12. ?*/??
  13. class?CTask??
  14. {??
  15. protected:??
  16. ????string?m_strTaskName;??/**?任務的名稱?*/??
  17. ????void*?m_ptrData;???????/**?要執行的任務的具體數據?*/??
  18. public:??
  19. ????CTask(){}??
  20. ????CTask(string?taskName)??
  21. ????{??
  22. ????????m_strTaskName?=?taskName;??
  23. ????????m_ptrData?=?NULL;??
  24. ????}??
  25. ????virtual?int?Run()=?0;??
  26. ????void?SetData(void*?data);????/**?設置任務數據?*/??
  27. ??
  28. public:??
  29. ????virtual?~CTask(){}??
  30. };??
  31. ??
  32. /**?
  33. ?*?線程池管理類的實現?
  34. ?*/??
  35. class?CThreadPool??
  36. {??
  37. private:??
  38. ????static??vector<CTask*>?m_vecTaskList;?????/**?任務列表?*/??
  39. ????static??bool?shutdown;????????????????????/**?線程退出標志?*/???????????
  40. ????int?????m_iThreadNum;?????????????????????/**?線程池中啟動的線程數?*/??
  41. ????pthread_t???*pthread_id;??
  42. ??????
  43. ????static?pthread_mutex_t?m_pthreadMutex;????/**?線程同步鎖?*/??
  44. ????static?pthread_cond_t?m_pthreadCond;??????/**?線程同步的條件變量?*/??
  45. ??
  46. protected:??
  47. ????static?void*?ThreadFunc(void?*?threadData);?/**?新線程的線程回調函數?*/??
  48. ????static?int?MoveToIdle(pthread_t?tid);???????/**?線程執行結束后，把自己放入到空閑線程中?*/??
  49. ????static?int?MoveToBusy(pthread_t?tid);???????/**?移入到忙碌線程中去?*/??
  50. ??????
  51. ????int?Create();??????????/**?創建線程池中的線程?*/??
  52. ??
  53. public:??
  54. ????CThreadPool(int?threadNum?=?10);??
  55. ????int?AddTask(CTask?*task);??????/**?把任務添加到任務隊列中?*/??
  56. ????int?StopAll();?????????????????/**?使線程池中的線程退出?*/??
  57. ????int?getTaskSize();?????????????/**?獲取當前任務隊列中的任務數?*/??
  58. };??
  59. ??
  60. #endif??
[cpp]?view plain?copy
  1. #ifndef?__THREAD_H??
  2. #define?__THREAD_H??
  3. ??
  4. #include?<vector>??
  5. #include?<string>??
  6. #include?<pthread.h>??
  7. ??
  8. using?namespace?std;??
  9. ??
  10. /**?
  11. ?*?執行任務的類，設置任務數據并執行?
  12. ?*/??
  13. class?CTask??
  14. {??
  15. protected:??
  16. ????string?m_strTaskName;??/**?任務的名稱?*/??
  17. ????void*?m_ptrData;???????/**?要執行的任務的具體數據?*/??
  18. public:??
  19. ????CTask(){}??
  20. ????CTask(string?taskName)??
  21. ????{??
  22. ????????m_strTaskName?=?taskName;??
  23. ????????m_ptrData?=?NULL;??
  24. ????}??
  25. ????virtual?int?Run()=?0;??
  26. ????void?SetData(void*?data);????/**?設置任務數據?*/??
  27. ??
  28. public:??
  29. ????virtual?~CTask(){}??
  30. };??
  31. ??
  32. /**?
  33. ?*?線程池管理類的實現?
  34. ?*/??
  35. class?CThreadPool??
  36. {??
  37. private:??
  38. ????static??vector<CTask*>?m_vecTaskList;?????/**?任務列表?*/??
  39. ????static??bool?shutdown;????????????????????/**?線程退出標志?*/???????????
  40. ????int?????m_iThreadNum;?????????????????????/**?線程池中啟動的線程數?*/??
  41. ????pthread_t???*pthread_id;??
  42. ??????
  43. ????static?pthread_mutex_t?m_pthreadMutex;????/**?線程同步鎖?*/??
  44. ????static?pthread_cond_t?m_pthreadCond;??????/**?線程同步的條件變量?*/??
  45. ??
  46. protected:??
  47. ????static?void*?ThreadFunc(void?*?threadData);?/**?新線程的線程回調函數?*/??
  48. ????static?int?MoveToIdle(pthread_t?tid);???????/**?線程執行結束后，把自己放入到空閑線程中?*/??
  49. ????static?int?MoveToBusy(pthread_t?tid);???????/**?移入到忙碌線程中去?*/??
  50. ??????
  51. ????int?Create();??????????/**?創建線程池中的線程?*/??
  52. ??
  53. public:??
  54. ????CThreadPool(int?threadNum?=?10);??
  55. ????int?AddTask(CTask?*task);??????/**?把任務添加到任務隊列中?*/??
  56. ????int?StopAll();?????????????????/**?使線程池中的線程退出?*/??
  57. ????int?getTaskSize();?????????????/**?獲取當前任務隊列中的任務數?*/??
  58. };??
  59. ??
  60. #endif??

?

實現文件

Thread.cpp

[cpp]?view plaincopy
  1. #include?"Thread.h"???
  2. #include?<iostream>???
  3. ??
  4. void?CTask::SetData(void?*?data)??
  5. {??
  6. ????m_ptrData?=?data;??
  7. }??
  8. ??
  9. vector<CTask*>?CThreadPool::m_vecTaskList;?????????//任務列表???
  10. bool?CThreadPool::shutdown?=?false;??
  11. ??????
  12. pthread_mutex_t?CThreadPool::m_pthreadMutex?=?PTHREAD_MUTEX_INITIALIZER;???
  13. pthread_cond_t?CThreadPool::m_pthreadCond?=?PTHREAD_COND_INITIALIZER;??
  14. ??
  15. /**?
  16. ?*?線程池管理類構造函數?
  17. ?*/??
  18. CThreadPool::CThreadPool(int?threadNum)??
  19. {??
  20. ????this->m_iThreadNum?=?threadNum;??
  21. ????cout?<<?"I?will?create?"?<<?threadNum?<<?"?threads"?<<?endl;??
  22. ????Create();??
  23. }??
  24. ??
  25. /**?
  26. ?*?線程回調函數?
  27. ?*/??
  28. void*?CThreadPool::ThreadFunc(void*?threadData)??
  29. {??
  30. ????pthread_t?tid?=?pthread_self();??
  31. ????while?(1)??
  32. ????{??
  33. ????????pthread_mutex_lock(&m_pthreadMutex);??
  34. ????????while?(m_vecTaskList.size()?==?0?&&?!shutdown)??
  35. ????????{??
  36. ????????????pthread_cond_wait(&m_pthreadCond,?&m_pthreadMutex);??
  37. ????????}??
  38. ??????????
  39. ????????if?(shutdown)??
  40. ????????{??
  41. ????????????pthread_mutex_unlock(&m_pthreadMutex);??
  42. ????????????printf("thread?%lu?will?exit/n",?pthread_self());??
  43. ????????????pthread_exit(NULL);???
  44. ????????}??
  45. ??????????
  46. ????????printf("tid?%lu?run/n",?tid);??
  47. ????????vector<CTask*>::iterator?iter?=?m_vecTaskList.begin();??
  48. ??????????
  49. ????????/**?
  50. ????????*?取出一個任務并處理之?
  51. ????????*/??
  52. ????????CTask*?task?=?*iter;??
  53. ????????if?(iter?!=?m_vecTaskList.end())??
  54. ????????{??
  55. ????????????task?=?*iter;??
  56. ????????????m_vecTaskList.erase(iter);??
  57. ????????}??
  58. ??????????
  59. ????????pthread_mutex_unlock(&m_pthreadMutex);??
  60. ??????????
  61. ????????task->Run();?/**?執行任務?*/??
  62. ????????printf("tid:%lu?idle/n",?tid);??
  63. ????}??
  64. ????return?(void*)0;??
  65. }??
  66. ??
  67. /**?
  68. ?*?往任務隊列里邊添加任務并發出線程同步信號?
  69. ?*/??
  70. int?CThreadPool::AddTask(CTask?*task)??
  71. {??
  72. ????pthread_mutex_lock(&m_pthreadMutex);??
  73. ????this->m_vecTaskList.push_back(task);??
  74. ????pthread_mutex_unlock(&m_pthreadMutex);??
  75. ????pthread_cond_signal(&m_pthreadCond);??
  76. ????return?0;??
  77. }??
  78. ??
  79. /**?
  80. ?*?創建線程?
  81. ?*/??
  82. int?CThreadPool::Create()??
  83. {??
  84. ????pthread_id?=?(pthread_t*)malloc(sizeof(pthread_t)?*?m_iThreadNum);??
  85. ????for(int?i?=?0;?i?<?m_iThreadNum;?i++)??
  86. ????{??
  87. ????????pthread_create(&pthread_id[i],?NULL,?ThreadFunc,?NULL);??
  88. ????}??
  89. ????return?0;??
  90. }??
  91. ??
  92. /**?
  93. ?*?停止所有線程?
  94. ?*/??
  95. int?CThreadPool::StopAll()??
  96. {??
  97. ????/**?避免重復調用?*/??
  98. ????if?(shutdown)??
  99. ????{??
  100. ????????return?-1;????
  101. ????}??
  102. ????printf("Now?I?will?end?all?threads!!/n");??
  103. ????/**?喚醒所有等待線程，線程池要銷毀了?*/??
  104. ????shutdown?=?true;??
  105. ????pthread_cond_broadcast(&m_pthreadCond);??
  106. ??????
  107. ????/**?阻塞等待線程退出，否則就成僵尸了?*/??
  108. ????for?(int?i?=?0;?i?<?m_iThreadNum;?i++)??
  109. ????{??
  110. ????????pthread_join(pthread_id[i],?NULL);????
  111. ????}??
  112. ??????
  113. ????free(pthread_id);??
  114. ????pthread_id?=?NULL;??
  115. ??????
  116. ????/**?銷毀條件變量和互斥體?*/??
  117. ????pthread_mutex_destroy(&m_pthreadMutex);??
  118. ????pthread_cond_destroy(&m_pthreadCond);??
  119. ??????
  120. ????return?0;??
  121. }??
  122. ??
  123. /**?
  124. ?*?獲取當前隊列中任務數?
  125. ?*/??
  126. int?CThreadPool::getTaskSize()??
  127. {??
  128. ????return?m_vecTaskList.size();??????
  129. }??
[cpp]?view plain?copy
  1. #include?"Thread.h"??
  2. #include?<iostream>??
  3. ??
  4. void?CTask::SetData(void?*?data)??
  5. {??
  6. ????m_ptrData?=?data;??
  7. }??
  8. ??
  9. vector<CTask*>?CThreadPool::m_vecTaskList;?????????//任務列表??
  10. bool?CThreadPool::shutdown?=?false;??
  11. ??????
  12. pthread_mutex_t?CThreadPool::m_pthreadMutex?=?PTHREAD_MUTEX_INITIALIZER;???
  13. pthread_cond_t?CThreadPool::m_pthreadCond?=?PTHREAD_COND_INITIALIZER;??
  14. ??
  15. /**?
  16. ?*?線程池管理類構造函數?
  17. ?*/??
  18. CThreadPool::CThreadPool(int?threadNum)??
  19. {??
  20. ????this->m_iThreadNum?=?threadNum;??
  21. ????cout?<<?"I?will?create?"?<<?threadNum?<<?"?threads"?<<?endl;??
  22. ????Create();??
  23. }??
  24. ??
  25. /**?
  26. ?*?線程回調函數?
  27. ?*/??
  28. void*?CThreadPool::ThreadFunc(void*?threadData)??
  29. {??
  30. ????pthread_t?tid?=?pthread_self();??
  31. ????while?(1)??
  32. ????{??
  33. ????????pthread_mutex_lock(&m_pthreadMutex);??
  34. ????????while?(m_vecTaskList.size()?==?0?&&?!shutdown)??
  35. ????????{??
  36. ????????????pthread_cond_wait(&m_pthreadCond,?&m_pthreadMutex);??
  37. ????????}??
  38. ??????????
  39. ????????if?(shutdown)??
  40. ????????{??
  41. ????????????pthread_mutex_unlock(&m_pthreadMutex);??
  42. ????????????printf("thread?%lu?will?exit/n",?pthread_self());??
  43. ????????????pthread_exit(NULL);???
  44. ????????}??
  45. ??????????
  46. ????????printf("tid?%lu?run/n",?tid);??
  47. ????????vector<CTask*>::iterator?iter?=?m_vecTaskList.begin();??
  48. ??????????
  49. ????????/**?
  50. ????????*?取出一個任務并處理之?
  51. ????????*/??
  52. ????????CTask*?task?=?*iter;??
  53. ????????if?(iter?!=?m_vecTaskList.end())??
  54. ????????{??
  55. ????????????task?=?*iter;??
  56. ????????????m_vecTaskList.erase(iter);??
  57. ????????}??
  58. ??????????
  59. ????????pthread_mutex_unlock(&m_pthreadMutex);??
  60. ??????????
  61. ????????task->Run();?/**?執行任務?*/??
  62. ????????printf("tid:%lu?idle/n",?tid);??
  63. ????}??
  64. ????return?(void*)0;??
  65. }??
  66. ??
  67. /**?
  68. ?*?往任務隊列里邊添加任務并發出線程同步信號?
  69. ?*/??
  70. int?CThreadPool::AddTask(CTask?*task)??
  71. {??
  72. ????pthread_mutex_lock(&m_pthreadMutex);??
  73. ????this->m_vecTaskList.push_back(task);??
  74. ????pthread_mutex_unlock(&m_pthreadMutex);??
  75. ????pthread_cond_signal(&m_pthreadCond);??
  76. ????return?0;??
  77. }??
  78. ??
  79. /**?
  80. ?*?創建線程?
  81. ?*/??
  82. int?CThreadPool::Create()??
  83. {??
  84. ????pthread_id?=?(pthread_t*)malloc(sizeof(pthread_t)?*?m_iThreadNum);??
  85. ????for(int?i?=?0;?i?<?m_iThreadNum;?i++)??
  86. ????{??
  87. ????????pthread_create(&pthread_id[i],?NULL,?ThreadFunc,?NULL);??
  88. ????}??
  89. ????return?0;??
  90. }??
  91. ??
  92. /**?
  93. ?*?停止所有線程?
  94. ?*/??
  95. int?CThreadPool::StopAll()??
  96. {??
  97. ????/**?避免重復調用?*/??
  98. ????if?(shutdown)??
  99. ????{??
  100. ????????return?-1;????
  101. ????}??
  102. ????printf("Now?I?will?end?all?threads!!/n");??
  103. ????/**?喚醒所有等待線程，線程池要銷毀了?*/??
  104. ????shutdown?=?true;??
  105. ????pthread_cond_broadcast(&m_pthreadCond);??
  106. ??????
  107. ????/**?阻塞等待線程退出，否則就成僵尸了?*/??
  108. ????for?(int?i?=?0;?i?<?m_iThreadNum;?i++)??
  109. ????{??
  110. ????????pthread_join(pthread_id[i],?NULL);????
  111. ????}??
  112. ??????
  113. ????free(pthread_id);??
  114. ????pthread_id?=?NULL;??
  115. ??????
  116. ????/**?銷毀條件變量和互斥體?*/??
  117. ????pthread_mutex_destroy(&m_pthreadMutex);??
  118. ????pthread_cond_destroy(&m_pthreadCond);??
  119. ??????
  120. ????return?0;??
  121. }??
  122. ??
  123. /**?
  124. ?*?獲取當前隊列中任務數?
  125. ?*/??
  126. int?CThreadPool::getTaskSize()??
  127. {??
  128. ????return?m_vecTaskList.size();??????
  129. }??

?

main函數文件

[cpp]?view plaincopy
  1. #include?"Thread.h"???
  2. #include?<iostream>???
  3. ??
  4. class?CMyTask:?public?CTask??
  5. {??
  6. public:??
  7. ????CMyTask(){}??
  8. ??????
  9. ????inline?int?Run()??
  10. ????{??
  11. ????????printf("%s/n",?(char*)this->m_ptrData);??
  12. ????????sleep(10);??
  13. ????????return?0;??
  14. ????}??
  15. };??
  16. ??
  17. int?main()??
  18. {??
  19. ????CMyTask?taskObj;??
  20. ??????
  21. ????char?szTmp[]?=?"this?is?the?first?thread?running";??
  22. ????taskObj.SetData((void*)szTmp);??
  23. ????CThreadPool?threadPool(10);??
  24. ??????
  25. ????for(int?i?=?0;?i?<?20;?i++)??
  26. ????{??
  27. ????????threadPool.AddTask(&taskObj);??
  28. ????}??
  29. ??????
  30. ????while(1)??
  31. ????{??
  32. ????????printf("there?are?still?%d?tasks?need?to?handle/n",?threadPool.getTaskSize());??
  33. ????????if?(threadPool.getTaskSize()?==?0)??
  34. ????????{??
  35. ????????????if?(threadPool.StopAll()?==?-1)??
  36. ????????????{?????
  37. ????????????????printf("Now?I?will?exit?from?main/n");??
  38. ????????????????exit(0);??
  39. ????????????}??
  40. ????????}??
  41. ????????sleep(2);??
  42. ????}??
  43. ??????
  44. ????return?0;??
  45. }??
[cpp]?view plain?copy
  1. #include?"Thread.h"??
  2. #include?<iostream>??
  3. ??
  4. class?CMyTask:?public?CTask??
  5. {??
  6. public:??
  7. ????CMyTask(){}??
  8. ??????
  9. ????inline?int?Run()??
  10. ????{??
  11. ????????printf("%s/n",?(char*)this->m_ptrData);??
  12. ????????sleep(10);??
  13. ????????return?0;??
  14. ????}??
  15. };??
  16. ??
  17. int?main()??
  18. {??
  19. ????CMyTask?taskObj;??
  20. ??????
  21. ????char?szTmp[]?=?"this?is?the?first?thread?running";??
  22. ????taskObj.SetData((void*)szTmp);??
  23. ????CThreadPool?threadPool(10);??
  24. ??????
  25. ????for(int?i?=?0;?i?<?20;?i++)??
  26. ????{??
  27. ????????threadPool.AddTask(&taskObj);??
  28. ????}??
  29. ??????
  30. ????while(1)??
  31. ????{??
  32. ????????printf("there?are?still?%d?tasks?need?to?handle/n",?threadPool.getTaskSize());??
  33. ????????if?(threadPool.getTaskSize()?==?0)??
  34. ????????{??
  35. ????????????if?(threadPool.StopAll()?==?-1)??
  36. ????????????{?????
  37. ????????????????printf("Now?I?will?exit?from?main/n");??
  38. ????????????????exit(0);??
  39. ????????????}??
  40. ????????}??
  41. ????????sleep(2);??
  42. ????}??
  43. ??????
  44. ????return?0;??
  45. }??

?

Makefile文件

[cpp]?view plaincopy
  1. CC?:=?g++??
  2. TARGET?:=?threadpool??
  3. INCLUDE?:=?-I./??
  4. LIBS?:=?-lpthread???
  5. ??
  6. #?C++語言編譯參數???
  7. CXXFLAGS?:=?-g?-Wall?-D_REENTRANT???
  8. ??
  9. #?C預處理參數???
  10. #?CPPFLAGS?:=????
  11. ??
  12. OBJECTS?:=?test.o?Thread.o???
  13. ??
  14. $(TARGET):?$(OBJECTS)???
  15. ????$(CC)?-o?$(TARGET)?$(OBJECTS)?$(LIBS)???
  16. ??
  17. #?$@表示所有目標集???
  18. %.o:%.cpp???
  19. ????$(CC)?-c?$(CXXFLAGS)?$(INCLUDE)?$<?-o?$@???
  20. ??
  21. .PHONY?:?clean??
  22. clean:???
  23. ????-rm?-f?$(OBJECTS)?$(TARGET)??
[cpp]?view plain?copy
  1. CC?:=?g++??
  2. TARGET?:=?threadpool??
  3. INCLUDE?:=?-I./??
  4. LIBS?:=?-lpthread???
  5. ??
  6. #?C++語言編譯參數??
  7. CXXFLAGS?:=?-g?-Wall?-D_REENTRANT???
  8. ??
  9. #?C預處理參數??
  10. #?CPPFLAGS?:=???
  11. ??
  12. OBJECTS?:=?test.o?Thread.o???
  13. ??
  14. $(TARGET):?$(OBJECTS)???
  15. ????$(CC)?-o?$(TARGET)?$(OBJECTS)?$(LIBS)???
  16. ??
  17. #?$@表示所有目標集??
  18. %.o:%.cpp???
  19. ????$(CC)?-c?$(CXXFLAGS)?$(INCLUDE)?$<?-o?$@???
  20. ??
  21. .PHONY?:?clean??
  22. clean:???
  23. ????-rm?-f?$(OBJECTS)?$(TARGET)??

?

在Linux上的輸出：

[xhtml]?view plaincopy
  1. I?will?create?10?threads??
  2. there?are?still?10?tasks?need?to?handle??
  3. tid?3086535568?run??
  4. this?is?the?first?thread?running??
  5. tid?3084434320?run??
  6. this?is?the?first?thread?running??
  7. tid?3082333072?run??
  8. this?is?the?first?thread?running??
  9. tid?3080231824?run??
  10. this?is?the?first?thread?running??
  11. tid?3078130576?run??
  12. this?is?the?first?thread?running??
  13. tid?3076029328?run??
  14. this?is?the?first?thread?running??
  15. tid?3073928080?run??
  16. this?is?the?first?thread?running??
  17. tid?3071826832?run??
  18. this?is?the?first?thread?running??
  19. tid?3069725584?run??
  20. this?is?the?first?thread?running??
  21. tid?3067624336?run??
  22. this?is?the?first?thread?running??
  23. there?are?still?0?tasks?need?to?handle??
  24. Now?I?will?end?all?threads!!??
  25. tid:3086535568?idle??
  26. tid:3078130576?idle??
  27. thread?3078130576?will?exit??
  28. tid:3076029328?idle??
  29. thread?3076029328?will?exit??
  30. tid:3073928080?idle??
  31. thread?3073928080?will?exit??
  32. tid:3071826832?idle??
  33. thread?3071826832?will?exit??
  34. tid:3069725584?idle??
  35. thread?3069725584?will?exit??
  36. tid:3067624336?idle??
  37. thread?3067624336?will?exit??
  38. tid:3084434320?idle??
  39. thread?3084434320?will?exit??
  40. thread?3086535568?will?exit??
  41. tid:3082333072?idle??
  42. thread?3082333072?will?exit??
  43. tid:3080231824?idle??
  44. thread?3080231824?will?exit??
  45. there?are?still?0?tasks?need?to?handle??
  46. Now?I?will?exit?from?main??
[xhtml]?view plain?copy
  1. I?will?create?10?threads??
  2. there?are?still?10?tasks?need?to?handle??
  3. tid?3086535568?run??
  4. this?is?the?first?thread?running??
  5. tid?3084434320?run??
  6. this?is?the?first?thread?running??
  7. tid?3082333072?run??
  8. this?is?the?first?thread?running??
  9. tid?3080231824?run??
  10. this?is?the?first?thread?running??
  11. tid?3078130576?run??
  12. this?is?the?first?thread?running??
  13. tid?3076029328?run??
  14. this?is?the?first?thread?running??
  15. tid?3073928080?run??
  16. this?is?the?first?thread?running??
  17. tid?3071826832?run??
  18. this?is?the?first?thread?running??
  19. tid?3069725584?run??
  20. this?is?the?first?thread?running??
  21. tid?3067624336?run??
  22. this?is?the?first?thread?running??
  23. there?are?still?0?tasks?need?to?handle??
  24. Now?I?will?end?all?threads!!??
  25. tid:3086535568?idle??
  26. tid:3078130576?idle??
  27. thread?3078130576?will?exit??
  28. tid:3076029328?idle??
  29. thread?3076029328?will?exit??
  30. tid:3073928080?idle??
  31. thread?3073928080?will?exit??
  32. tid:3071826832?idle??
  33. thread?3071826832?will?exit??
  34. tid:3069725584?idle??
  35. thread?3069725584?will?exit??
  36. tid:3067624336?idle??
  37. thread?3067624336?will?exit??
  38. tid:3084434320?idle??
  39. thread?3084434320?will?exit??
  40. thread?3086535568?will?exit??
  41. tid:3082333072?idle??
  42. thread?3082333072?will?exit??
  43. tid:3080231824?idle??
  44. thread?3080231824?will?exit??
  45. there?are?still?0?tasks?need?to?handle??
  46. Now?I?will?exit?from?main??

?


本文來自互聯網用戶投稿，該文觀點僅代表作者本人，不代表本站立場。本站僅提供信息存儲空間服務，不擁有所有權，不承擔相關法律責任。
如若轉載，請注明出處：http://www.pswp.cn/news/383764.shtml
繁體地址，請注明出處：http://hk.pswp.cn/news/383764.shtml
英文地址，請注明出處：http://en.pswp.cn/news/383764.shtml

如若內容造成侵權/違法違規/事實不符，請聯系多彩編程網進行投訴反饋email:809451989@qq.com，一經查實，立即刪除！

相關文章

樹啟發式合并入門

樹啟發式合并入門

所謂啟發式合并&#xff0c;就是一種符合直覺的合并方法&#xff1a;將小的子樹合并在大的子樹上。 這些問題一般是相似的問題背景&#xff1a;都是樹上的計數問題&#xff0c;都不能直接從上往下進行暴力&#xff0c;都需要從下往上計數時對子樹信息進行運算從而得到父親節點的…
閱讀更多...
鏈棧基本操作

鏈棧基本操作

http://blog.csdn.net/jwentao01/article/details/46765517###;棧基本概念&#xff1a; 棧&#xff08;stack&#xff09;是限定在表尾進行插入和刪除操作的線性表&#xff08;或單鏈表&#xff09;。 //只能在一段進行插入和刪除&#xff0c;因此不存在&#xff0c;在中間進行…
閱讀更多...
Linux網絡編程---I/O復用模型之select

Linux網絡編程---I/O復用模型之select

https://blog.csdn.net/men_wen/article/details/53456435Linux網絡編程—I/O復用模型之select 1. IO復用模型 IO復用能夠預先告知內核&#xff0c;一旦發現進程指定的一個或者多個IO條件就緒&#xff0c;它就通知進程。IO復用阻塞在select或poll系統調用上&#xff0c;而不是阻…
閱讀更多...
UVa12633-Super Rooks on Chessboard-容斥+FFT

UVa12633-Super Rooks on Chessboard-容斥+FFT

題目大意就是給你一個R*C的棋盤&#xff0c;上面有超級兵&#xff0c;這種超級兵會攻擊 同一行、同一列、同一主對角線的所有元素&#xff0c;現在給你N個超級兵的坐標&#xff0c;需要你求出有多少方塊是不能被攻擊到的(R,C,N<50000) 遇到這種計數問題就要聯想到容斥&#…
閱讀更多...
Linux網絡編程---I/O復用模型之poll

Linux網絡編程---I/O復用模型之poll

https://blog.csdn.net/men_wen/article/details/53456474Linux網絡編程—I/O復用模型之poll 1.函數poll poll系統調用和select類似&#xff0c;也是在指定時間內輪詢一定數量的文件描述符&#xff0c;以測試其中是否有就緒者。 #include <poll.h>int poll(struct pollfd…
閱讀更多...
FFT模板

FFT模板

整理了一下&#xff0c;自己寫了一下模板 const double PIacos(-1.0); struct complex {double r,i;complex(double _r0,double _i0):r(_r),i(_i){}complex operator (const complex &b) {return complex(rb.r,ib.i);}complex operator -(const complex &b) {return c…
閱讀更多...
Linux網絡編程---I/O復用模型之epoll

Linux網絡編程---I/O復用模型之epoll

https://blog.csdn.net/men_wen/article/details/53456474 Linux網絡編程—I/O復用模型之epoll 1. epoll模型簡介 epoll是Linux多路服用IO接口select/poll的加強版&#xff0c;e對應的英文單詞就是enhancement&#xff0c;中文翻譯為增強&#xff0c;加強&#xff0c;提高&…
閱讀更多...
POJ 1741tree-點分治入門

POJ 1741tree-點分治入門

學習了一下點分治&#xff0c;如果理解有誤還請不吝賜教。 為了快速求得樹上任意兩點之間距離滿足某種關系的點對數&#xff0c;我們需要用到這種算法。 點分治是樹上的一種分治算法&#xff0c;依靠樹和子樹之間的關系進行分治從而降低復雜度。 和其他樹上的算法有一些區別…
閱讀更多...
基于單鏈表的生產者消費者問題

基于單鏈表的生產者消費者問題

『生產者與消費者問題分析』「原理」生產者生產產品&#xff0c;消費者消費產品。產品如果被消費者消費完了&#xff0c;同時生產者又沒有生產出產品&#xff0c;消費者 就必須等待。同樣的&#xff0c;如果生產者生產了產品&#xff0c;而消費者沒有去消費&#x…
閱讀更多...
C++智能指針（一）智能指針的簡單介紹

C++智能指針（一）智能指針的簡單介紹

https://blog.csdn.net/nou_camp/article/details/70176949C智能指針 在正式了解智能指針前先看一下下面的一段代碼 #include<iostream> using namespace std; class A { public:A():_ptr(NULL), _a(0){}~A(){} public:int* _ptr;int _a; };void test() {A a;int *p1 ne…
閱讀更多...
聰聰可可-點分治

聰聰可可-點分治

聰聰和可可是兄弟倆&#xff0c;他們倆經常為了一些瑣事打起來&#xff0c;例如家中只剩下最后一根冰棍而兩人都想吃、兩個人都想玩兒電腦&#xff08;可是他們家只有一臺電腦&#xff09;……遇到這種問題&#xff0c;一般情況下石頭剪刀布就好了&#xff0c;可是他們已經玩兒…
閱讀更多...
C++智能指針（二）模擬實現三種智能指針

C++智能指針（二）模擬實現三種智能指針

https://blog.csdn.net/nou_camp/article/details/70186721在上一篇博客中提到了Auto_ptr(C智能指針&#xff08;一&#xff09;)&#xff0c;下面進行模擬實現Auto_ptr 采用類模板實現 #include<iostream> using namespace std; template<class T> class Autoptr …
閱讀更多...
Prime Distance On Tree-樹分治+FFT

Prime Distance On Tree-樹分治+FFT

題目描述 Problem description. You are given a tree. If we select 2 distinct nodes uniformly at random, what’s the probability that the distance between these 2 nodes is a prime number? Input The first line contains a number N: the number of nodes in this…
閱讀更多...
C++智能指針（三）總結

C++智能指針（三）總結

https://blog.csdn.net/nou_camp/article/details/70195795 在上一篇博客中&#xff08;C智能指針&#xff08;二&#xff09;&#xff09;模擬實現了三種智能指針。 其中最好的就是shared_ptr,但是這并不代表它就是最完美的&#xff0c;它也有問題&#xff0c;這個問題就是循環…
閱讀更多...
POJ2114-Boatherds-樹分治

POJ2114-Boatherds-樹分治

題目描述 Boatherds Inc. is a sailing company operating in the country of Trabantustan and offering boat trips on Trabantian rivers. All the rivers originate somewhere in the mountains and on their way down to the lowlands they gradually join and finally th…
閱讀更多...
c++11 你需要知道這些就夠了

c++11 你需要知道這些就夠了

https://blog.csdn.net/tangliguantou/article/details/50549751c11新特性舉著火把尋找電燈今天我就權當拋磚引玉&#xff0c;如有不解大家一起探討。有部分內容是引用自互聯網上的內容&#xff0c;如有問題請聯系我。T&& 右值引用 std::move 右值引用出現之前我們只能…
閱讀更多...
HDU5977-Garden of Eden-樹分治+FWT

HDU5977-Garden of Eden-樹分治+FWT

題目描述 When God made the first man, he put him on a beautiful garden, the Garden of Eden. Here Adam lived with all animals. God gave Adam eternal life. But Adam was lonely in the garden, so God made Eve. When Adam was asleep one night, God took a rib fro…
閱讀更多...
C++11新特性學習

C++11新特性學習

https://blog.csdn.net/tennysonsky/article/details/778170481、什么是C11C11標準為C編程語言的第三個官方標準&#xff0c;正式名叫ISO/IEC 14882:2011 - Information technology -- Programming languages -- C。在正式標準發布前&#xff0c;原名C0x。它將取代C標準第二版I…
閱讀更多...
C++ override 關鍵字用法

C++ override 關鍵字用法

override關鍵字作用&#xff1a; 如果派生類在虛函數聲明時使用了override描述符&#xff0c;那么該函數必須重載其基類中的同名函數&#xff0c;否則代碼將無法通過編譯。舉例子說明struct Base {virtual void Turing() 0;virtual void Dijkstra() 0;virtual void VNeumann…
閱讀更多...
Gym - 101981I-MagicPotion-最大流

Gym - 101981I-MagicPotion-最大流

題目描述 There are n heroes and m monsters living in an island. The monsters became very vicious these days, so the heroes decided to diminish the monsters in the island. However, the i-th hero can only kill one monster belonging to the set Mi. Joe, the st…
閱讀更多...
最新文章

Copyright @ 2022~2023