Contributors

Stargazers

Forkers

konanrobot icaas iq17 xiaoweichen ricardo666666 ioxuy chenbk85 oronge awesomeleo woniuxu yuufish guker zjzstu zhyongprimer superskeet lengender jaredyedh geeksroad lishuai1225 desert0616 strom109212 chakpongchung tisan2021 grimxiaojun anryyang study-of-slag-weng sinomiko treycheng skyformat99 ctzhenghua jerrywang2023 jackros1022 xhafei 544892012 hellolinux bye430 layeka shawvi tycao ucrone jingchenzhong zzzatn myghk2015 fsj2001 shawind yuncodeclass morefreeze tide999 lixiang1993hlju pj520 zacklin923 secondzc wuli133144 fangyixing cz2013 kileven yangshaoguang luowei11108403 rockingroll internetbroker liaozhipeng sicoyu chenxianggui qweersad deguang1996 bytexiaotang stoneboy100200 lvyanhui sunwenfeng a574751346 willku1024 goudanli kanghaibo bottle1024 noel1992 lizilong008 eq94 zhouq3405 airob0t jinkehust jeremywangjun linglongxian wanily zenwisty alanding1989 black8mamba freemindhack leckel2014 dianbian xiangqingpdd haidaidaihai maonie zwxlib jhonconal lingaojun nxdesmend houyideng zjf984078330 lipq525 program-cn

void* ThreadPool::threadFunc(void* arg)
    {
        pthread_t tid = pthread_self();
        ThreadPool* pool = static_cast<ThreadPool*>(arg);
        while (pool->isRunning_)
        {
            pthread_mutex_lock(&pool->mutex_);
            while (pool->taskQueue_.empty() && pool->isRunning_) {
                pthread_cond_wait(&pool->condition_, &pool->mutex_);
            }

            Task* task = pool->taskQueue_.front();
            pool->taskQueue_.pop_front();

            pthread_mutex_unlock(&pool->mutex_);
            task->run();
        }
        return 0;
    }

    int ThreadPool::createThreads()
    {
            pthread_mutex_init(&mutex_, NULL);
            pthread_cond_init(&condition_, NULL);
            threads_ = (pthread_t*)malloc(sizeof(pthread_t) * threadsNum_);
            for (int i = 0; i < threadsNum_; i++)
            {
                    pthread_create(&threads_[i], NULL, threadFunc, this); // <= 这里调用了threadFunc
            }
            return 0;
    }
    void* ThreadPool::threadFunc(void* arg)
    {
            pthread_t tid = pthread_self();
            ThreadPool* pool = static_cast<ThreadPool*>(arg);
            while (pool->isRunning_)   <= 这里;isRunning_没有初始化就拿来使用了.
            {
                    Task* task = pool->take();
                    if (!task)
                    {
                            printf("thread %lu will exit\n", tid);
                            break;
                    }

                    assert(task);
                    task->run();
            }
            return 0;
    }