[并发并行]_[初级]_[C++实现sychronized方式的对象锁]

#include "pthread.h" #include <stdlib.h> #include <iostream> #include <stdint.h> #include <assert.h> #include <string> #include <vector> #include "aa_lock.h" static const int gMaxCountTime = 10000; static const int gTextThreadNum = 100; static pthread_t ts[gTextThreadNum]; static int64_t gCount = 0; static std::vector<int> gCountArray; void* StartPthread(void* data) { for (int i = 0; i < gMaxCountTime; ++i) { // 去掉锁的话,下边的assert随时crash. // 可对对象加锁,类似objc或Java的同步关键字sychronized AALock::GLock(&gCount); ++gCount; AALock::GUnLock(&gCount); // 去掉锁,push_back随时崩溃,因为vector并不是线程安全的. AALock::GLock(&gCountArray); gCountArray.push_back(i); AALock::GUnLock(&gCountArray); } return NULL; } void TestAALock() { for (int i = 0; i < gTextThreadNum; ++i) { pthread_create(&ts[i],NULL,StartPthread,NULL); } for (int i = 0; i < gTextThreadNum; ++i) { pthread_join(ts[i],NULL); } std::cout << "gCount: " << gCount << std::endl; assert(gCount == gMaxCountTime*gTextThreadNum); std::cout << "gCountArray size: " << gCountArray.size() << std::endl; assert(gCount == gCountArray.size()); } int main(int argc, char const *argv[]) { for (int i = 0; i < 10; ++i) { TestAALock(); gCount = 0; gCountArray.clear(); } return 0; }