• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

C++ condition_variable类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了C++中condition_variable的典型用法代码示例。如果您正苦于以下问题:C++ condition_variable类的具体用法?C++ condition_variable怎么用?C++ condition_variable使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



在下文中一共展示了condition_variable类的11个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的C++代码示例。

示例1: CPU_WaitStatus

void CPU_WaitStatus(condition_variable &cond, bool (*pred)()) {
	lock_guard guard(cpuThreadLock);
	while (!pred()) {
		cond.wait(cpuThreadLock);
	}
}
开发者ID:ThomasWDonnelly,项目名称:ppsspp,代码行数:6,代码来源:System.cpp


示例2: main

int main(int argc, char *argv[])
{
    if (argc != 4 && argc != 5)
    {
        cout << "Put \"[host-ipaddress:port] [authprovider] [authcode]\" for sign-up and sign-in"
             << endl;
        cout << "Put \"[host-ipaddress:port] [uid] [accessToken] 1\" for sign-in" <<
             endl;
        return 0;
    }

    OCPersistentStorage ps{ client_open, fread, fwrite, fclose, unlink };

    PlatformConfig cfg
    {
        ServiceType::InProc,
        ModeType::Both,
        "0.0.0.0", // By setting to "0.0.0.0", it binds to all available interfaces
        0,         // Uses randomly available port
        QualityOfService::LowQos,
        &ps
    };

    OCPlatform::Configure(cfg);

    OCStackResult result = OC_STACK_ERROR;

    string host = "coap+tcp://";
    host += argv[1];

    OCAccountManager::Ptr accountMgr = OCPlatform::constructAccountManagerObject(host,
                                       CT_ADAPTER_TCP);

    mutex blocker;
    unique_lock<mutex> lock(blocker);

    if (argc == 5)
    {
        accountMgr->signIn(argv[2], argv[3], &handleLoginoutCB);
        g_callbackLock.wait(lock);
    }
    else
    {
        accountMgr->signUp(argv[2], argv[3], &handleLoginoutCB);
        g_callbackLock.wait(lock);
        accountMgr->signIn(g_uid, g_accesstoken, &handleLoginoutCB);
        g_callbackLock.wait(lock);
    }

    // MQ broker resource
    g_mqBrokerResource = OCPlatform::constructResourceObject(host, DEFAULT_MQ_BROKER_URI,
                         static_cast<OCConnectivityType>(CT_ADAPTER_TCP | CT_IP_USE_V4), false,
    { string("oic.wk.ps") }, { string(DEFAULT_INTERFACE) });

    cout << "===Message Queue publisher sample===" << endl;
    cout << "PUT 0 to discover all topics" << endl;
    cout << "PUT 1 to discover type based topics" << endl;
    cout << "PUT 2 to select topic index for publishing data" << endl;
    cout << "PUT 3 to publish data to selected topic" << endl;
    cout << "PUT 4 to create topic" << endl;
    cout << "PUT 5 to create type based topic" << endl;

    string cmd;

    while (true)
    {
        cin >> cmd;

        try
        {

            QueryParamsMap query;
            OCRepresentation rep;
            string      topicType;

            switch (cmd[0])
            {
                case '0':
                    gTopicList.clear();
                    cout << "Discovering topics" << endl;
                    result = g_mqBrokerResource->discoveryMQTopics(query, &discoverTopicCB, QualityOfService::LowQos);
                    break;

                case '1':
                    gTopicList.clear();
                    cout << "Put topic type to discover: ";
                    cin >> cmd;
                    query["rt"] = cmd;
                    result = g_mqBrokerResource->discoveryMQTopics(query, &discoverTopicCB, QualityOfService::LowQos);
                    break;

                case '2':
                    cout << "Put discovered topic index to select: ";
                    cin >> cmd;
                    {
                        int index = atoi(cmd.c_str());
                        if (index < 0 || (unsigned int) index >= gTopicList.size())
                        {
                            cout << "invalid topic index selected" << endl;
                            continue;
//.........这里部分代码省略.........
开发者ID:drashti304,项目名称:TizenRT,代码行数:101,代码来源:mq_publisher.cpp


示例3: process

    // running in a dedicated thread
    void process() {
        int clear_index;
        {
            unique_lock<mutex> auto_lock(cur_lock);
            cond.wait(auto_lock);
            clear_index = (cur_index + 2) % 3;
            int next_index = (cur_index + 1) % 3;
            cur_index = next_index;
            cur_set = &queue[next_index];
        }
        auto back_set = &queue[clear_index];

        auto it = back_set->begin();
        while (it != back_set->end()) {
            file_entry_t fe = *it;
            grandet_sync_task_t sync_task = NULL;
            grandet_remove_task_t remove_task = NULL;
            _files_lock.lock();
            INFO("processing %s\n", fe->link.c_str());
            if (fe->deleted) {
                INFO("processing deleted fe, size=%ld, fetched=%d, open_rc=%d\n", fe->st.st_size, fe->fetched, fe->open_rc);
            }
            if (fe->deleted && fe->open_rc == 0) {
                // when it is out of tree, no one can open it anymore 
                if (fe->deleted == 1) {
                    string data_path;
                    if (fe->fetched)
                        cache_remove(fe->st.st_size);
                    get_data_path(data_path, _data_store_base, fe->link.c_str());
                    grandet_remove_task_start(fe->link.c_str(), data_path.c_str(), &remove_task);
                    grandet_remove_task_wait(remove_task);
                    grandet_remove_task_end(remove_task);
                    
                    fe->deleted = 2; // avoiding repeated deletion
                }
                fe_put(fe);
            } else {
                // Update
                if (fe->content_dirty) {
                    if (!S_ISREG(fe->st.st_mode)) {
                        DEBUG("flush a non-regular file");
                    }
                    
                    string data_path;
                    get_data_path(data_path, _data_store_base, fe->link.c_str());
                    
                    fe->content_dirty = 0;
                    grandet_sync_task_start(fe->link.c_str(), data_path.c_str(), fe->xattr, &sync_task);
                    
                    _files_lock.unlock();
                    grandet_sync_task_wait(sync_task);
                    grandet_sync_task_end(sync_task);
                    _files_lock.lock();

                    // during the unlock and lock, there may be some
                    // thread writing data in and close, causing
                    // content_dirty be 1 again. Or some one can even
                    // delete it.  In those cases, it will appear in
                    // update queue again.
                    if (fe->open_rc == 0 && fe->fetched == 1 &&
                        fe->content_dirty == 0 && fe->deleted == 0) {
                        // DEBUG("add %s to idle list\n", fe->link.c_str());
                        // LRU
                        if (!list_empty(&fe->u_node))
                            list_del_init(&fe->u_node);
                        INFO("add %s to idle_list (dirty)\n", fe->link.c_str());
                        list_add_before(&_idle_list, &fe->u_node);
                    }
                } else if (fe->fetched == 1 && fe->open_rc == 0) {
                    if (!list_empty(&fe->u_node))
                        list_del_init(&fe->u_node);
                    INFO("add %s to idle_list (clean)\n", fe->link.c_str());
                    list_add_before(&_idle_list, &fe->u_node);
                }
                fe_put(fe);
            }
            _files_lock.unlock();
            ++ it;
        }
        back_set->clear();
    }
开发者ID:columbia,项目名称:grandet,代码行数:82,代码来源:main.cpp


示例4: CPU_SetState

void CPU_SetState(CPUThreadState to) {
	lock_guard guard(cpuThreadLock);
	cpuThreadState = to;
	cpuThreadCond.notify_one();
	cpuThreadReplyCond.notify_one();
}
开发者ID:ThomasWDonnelly,项目名称:ppsspp,代码行数:6,代码来源:System.cpp


示例5: draw

	void draw() {
		static int frameIndex = 0;
		ovrHmd_BeginFrame(hmd, frameIndex++);
		short textureSwitch = 0;// frameIndex % 2;

		// wait for camera thread
		{
			unique_lock<mutex> lck(camMutex);

			while (!camFinish){
				camFinishCondition.wait(lck);
			}
		}

		// swap image pointers
		for (int i = 0; i < 2; ++i)
		{
			IplImage* tempImage = perEyeReadImage[i];
			perEyeReadImage[i] = perEyeWriteImage[i];
			perEyeWriteImage[i] = tempImage;
		}

		// notify camera thread to resume
		{
			unique_lock<mutex> lck(camMutex);
			camFinish = false;
			drawFinish = true;
			drawFinishCondition.notify_all();
		}

		for (int i = 0; i < 2; ++i)
		{
			ovrEyeType eye = hmdDesc.EyeRenderOrder[i];

			if (perEyeReadImage[eye] && !terminateApp) {
				EyeArgs & eyeArgs = perEyeArgs[eye];
				gl::Stacks::projection().top() = eyeArgs.projection;
				gl::MatrixStack & mv = gl::Stacks::modelview();

				eyeArgs.framebuffer.activate();
				ovrPosef renderPose = ovrHmd_BeginEyeRender(hmd, eye);
				mv.withPush([&]{
					glClear(GL_DEPTH_BUFFER_BIT);
					//GlUtils::renderFloorGrid(glm::mat4());
					//GlUtils::renderSkybox(Resource::IMAGES_SKY_CITY_XNEG_PNG);

					if (ovrEye_Left == eye) {
						mv.rotate(M_PI / 2, glm::vec3(0, 0, 1));
					}
					else {
						mv.rotate(-M_PI / 2, glm::vec3(0, 0, 1));
					}

					mv.scale(1);
					mv.rotate(M_PI, glm::vec3(0, 1, 0));

					// only load necessary part of image
					glPixelStorei(GL_UNPACK_ROW_LENGTH, CAM_IMAGE_WIDTH);
					glPixelStorei(GL_UNPACK_SKIP_PIXELS, 189);

					// bind and load camera image
					imageTextures[eye]->bind();
					glTexSubImage2D(GL_TEXTURE_2D, 0, 0, 0, RENDER_IMAGE_WIDTH, RENDER_IMAGE_HEIGHT, GL_BGR, GL_UNSIGNED_BYTE, perEyeReadImage[eye]->imageData);

					glPixelStorei(GL_UNPACK_ROW_LENGTH, 0);
					glPixelStorei(GL_UNPACK_SKIP_PIXELS, 0);

					GlUtils::renderGeometry(quadGeom, texturedPtr);
				});

				ovrHmd_EndEyeRender(hmd, eye, renderPose, &perEyeArgs[eye].textures.Texture);
			}
			//eyeArgs.framebuffer.deactivate();
		};
		ovrHmd_EndFrame(hmd);
	}
开发者ID:davidshisui,项目名称:IRE,代码行数:76,代码来源:Main_LiveVideo.cpp


示例6: release

	void release(){
		unique_lock<mutex> lck(mtx);
        ++count;
        cv.notify_all();
	}
开发者ID:miezis,项目名称:ConcurrentProgramming,代码行数:5,代码来源:MiezinasM_L2g.cpp


示例7: updateCameraImages

	void updateCameraImages() {
		CvCapture* camLeft = cvCaptureFromCAM(701);
		cvSetCaptureProperty(camLeft, CV_CAP_PROP_FOURCC, CV_FOURCC('M', 'J', 'P', 'G'));
		cvSetCaptureProperty(camLeft, CV_CAP_PROP_FRAME_WIDTH, CAM_IMAGE_WIDTH);
		cvSetCaptureProperty(camLeft, CV_CAP_PROP_FRAME_HEIGHT, CAM_IMAGE_HEIGHT);

		CvCapture* camRight = cvCaptureFromCAM(700);
		cvSetCaptureProperty(camRight, CV_CAP_PROP_FOURCC, CV_FOURCC('M', 'J', 'P', 'G'));
		cvSetCaptureProperty(camRight, CV_CAP_PROP_FRAME_WIDTH, CAM_IMAGE_WIDTH);
		cvSetCaptureProperty(camRight, CV_CAP_PROP_FRAME_HEIGHT, CAM_IMAGE_HEIGHT);

		IplImage *imageLeft;
		IplImage *imageRight;
		float         fps = 0.f;
		int framecount = 0;
		long start = Platform::elapsedMillis();

		while (!terminateApp) {
			// wait on draw thread
				{
					unique_lock<mutex> lck(camMutex);
					while (!drawFinish && !terminateApp) { drawFinishCondition.wait(lck); }
				}

			imageLeft = cvQueryFrame(camLeft);
			if (imageLeft) {
				memcpy(perEyeWriteImage[0]->imageData, imageLeft->imageData, CAM_IMAGE_HEIGHT * CAM_IMAGE_WIDTH * 3);
			}
			else{
				SAY("Didn't get image of left cam");
			}

			imageRight = cvQueryFrame(camRight);
			if (imageRight) {
				memcpy(perEyeWriteImage[1]->imageData, imageRight->imageData, CAM_IMAGE_HEIGHT * CAM_IMAGE_WIDTH * 3);
			}
			else {
				SAY("Didn't get image of right cam");
			}

			long now = Platform::elapsedMillis();
			++framecount;
			if ((now - start) >= 2000) {
				float elapsed = (now - start) / 1000.f;
				fps = (float)framecount / elapsed;
				SAY("FPS cams: %0.2f\n", fps);
				start = now;
				framecount = 0;
			}

			{
				unique_lock<mutex> lck(camMutex);
				drawFinish = false;
				camFinish = true;
				camFinishCondition.notify_all();
			}

		}

		cvReleaseCapture(&camLeft);
		cvReleaseCapture(&camRight);
	}
开发者ID:davidshisui,项目名称:IRE,代码行数:62,代码来源:Main_LiveVideo.cpp


示例8: wait_for_cloud

void wait_for_cloud(uint n = 1) {
    // Wait until the cloud cb notifies us
    uint64_t old_cloud_count = cloud_count;
    unique_lock<std::mutex> unique_lock(cloud_count_lock);
    cloud_count_cv.wait(unique_lock, [=]{ return old_cloud_count + n <= cloud_count; });
}
开发者ID:utexas-bwi,项目名称:bwi_common,代码行数:6,代码来源:tabletop_scene_perception_node.cpp


示例9: ThreadCondition1

// Thread function: Condition notifier
void ThreadCondition1(void * aArg)
{
  lock_guard<mutex> lock(gMutex);
  -- gCount;
  gCond.notify_all();
}
开发者ID:strobe,项目名称:TinyThread-for-marmalade,代码行数:7,代码来源:test.cpp


示例10: WakeUpThread

	void WakeUpThread() {
		_noWork.notify_one();
	}
开发者ID:zeeshanabid94,项目名称:Barnes-Hut-N-Body-Simulation,代码行数:3,代码来源:threadedquadtree.cpp


示例11:

	~QuadTreeThread() {
		_running = false;
		_noWork.notify_one();
	}
开发者ID:zeeshanabid94,项目名称:Barnes-Hut-N-Body-Simulation,代码行数:4,代码来源:threadedquadtree.cpp



注:本文中的condition_variable类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
C++ conditional类代码示例发布时间:2022-05-31
下一篇:
C++ concurrent_queue类代码示例发布时间:2022-05-31
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap