草庐IT

非阻塞

全部标签

c++ - Boost.Asio strand.dispatch() 可以阻塞吗?

我正在试验Boost.Asiostrand对于我正在编写的服务器,我想澄清一些事情。假设我们有SomeClass,其中包含如下内容:voidSomeClass::foo(){strand_.dispatch(boost::bind(&SomeClass::bar,this));}此外,strand有一个io_service,多个线程调用run()。在strand::dispatch()上的文档中我读到它保证通过strand发布或调度的处理程序不会同时执行,如果满足此条件,则处理程序可能在此函数中执行。什么决定了处理程序是否立即执行?在这种多线程的情况下,如果多个io_service线程

c++ - 一个阻塞但非模态的 QDialog?

我有一堆图像,我想对其执行一些操作。处理每张图像后,我的程序应弹出一个对话框,提示用户是要继续处理下一张图像还是要中止。在此之前,他们应该有机会对图像或参数进行一些手动更改。无论如何,他们必须能够访问应用程序的窗口,而调用对话框的方法的执行应该被阻止,直到对话框关闭。我试图用QMessageBox解决这个问题,但如果我通过exec()打开它,它会阻塞整个应用程序,如果我使用show(),程序会继续执行而无需等待用户的react。有没有一种方便的方法可以通过对话框阻止调用方法或函数,但允许用户与其他窗口交互?提前感谢您的任何提示。 最佳答案

c++ - 高吞吐量非阻塞服务器设计 : Alternatives to busy wait

我一直在构建一个用于多媒体消息传递的高吞吐量服务器应用程序,实现语言是C++。每个服务器都可以独立使用,也可以将许多服务器连接在一起以创建基于DHT的覆盖网络;服务器就像Skype中的super节点一样。工作正在进行中。目前,服务器每秒可以处理大约200,000条消息(256字节消息),并且在我的机器(Inteli3Mobile2GHz、FedoraCore18(64位)、4GBRAM)上的最大吞吐量约为256MB/s长度为4096字节的消息。服务器有两个线程,一个线程用于处理所有IO(基于epoll,边缘触发),另一个线程用于处理传入消息。覆盖管理还有另一个线程,但在当前讨论中无关紧

c++ - 是否有用于阻塞 boost::asio TCP 连接的 boost::iostreams(双向)设备?

我正在研究可移植的C++库,阻止对文件系统和网络的I/O访问。看起来boost::filesystem、boost::iostreams和boost::asio将介于这三者之间他们的工作。明确地说,我目前对boost::asio的异步方面不感兴趣;我只想要一个可移植的阻塞式网络接口(interface)。深入研究,我看到boost::iostreams有一个设备的概念,每个设备都有一个关联的modeconcept.双向模式似乎专门为流式访问全双工TCP连接而量身定制。太棒了。boost::iostreams似乎不支持实际打开TCP连接(与本地文件系统不同。)没关系,boost::asi

c++ - 非阻塞 worker - 中断文件复制

我正在处理非常大的文件,大小超过数百GB。用户需要能够在磁盘之间移动这些文件,并且在没有默认文件管理器的受限系统上。用户有可能意识到他们犯了错误并取消操作,据我所知,用户将不得不等待当前的复制或重命名操作完成。这可能会让他们感到沮丧,因为他们可能会等待几分钟,却发现他们的许多GB文件仍然被复制。在复制的情况下,我可以删除第二个文件,但在我用来移动文件的重命名的情况下,我必须反向重复操作以撤消它,这是NotAcceptable。有没有什么方法可以中断我在QFile的文档中没有看到的copy()和rename(),或者我是否需要将我自己的类放在一起来处理复制和重命名?

c++ - MFC UpdateAllViews 是阻塞还是非阻塞?

我有一个基于文档View框架的MFC代码。我使用Document类中的UpdateAllViews(nullptr,0,nullptr)来调用View的OnDraw成员函数。voidMyDocumentClass::MyFunction(){//..DocumentcodetocreateandprocessdataUpdateAllViews(nullptr,0,nullptr)//InvokesOnDraw//Whendoesprogramcontrolreachthisline?}我的问题是,请告诉我UpdateAllViews函数是阻塞的还是非阻塞的,程序控制什么时候到达Upd

C++ 服务器端不阻塞 listen()

下面的代码不会阻塞在listen()上,它只是完成执行。你能告诉我为什么吗?(initWSA返回true,我查过了)。我正在学习一个教程,我被告知它应该阻止,因为它正在寻找要连接的客户端。#include#include#pragmacomment(lib,"ws2_32.lib")usingnamespacestd;#definePORT10000boolinitWSA(){WSADATAwsadata;interror=WSAStartup(0x0202,&wsadata);if(error)returnfalse;if(wsadata.wVersion!=0x0202){WSAC

c++ - 导致 C++11 std::mutex 将阻塞的线程锁定为被动等待状态?

我有以下情况:两个C++11线程正在计算,它们通过std::mutex同步。线程A锁定互斥锁,直到数据准备好供线程B执行的操作使用。当互斥量解锁时,线程B开始工作。线程B试图锁定互斥量并被阻塞,直到它被线程A解锁。voidThreadA(std::mutex*mtx,char*data){mtx->lock();//dosomethingusefulwithdatamtx->unlock();}voidThreadB(std::mutex*mtx,char*data){mtx->lock();//waituntilThreadAisready//dosomethingusefulwit

c++ - recv 阻塞时如何正确清理?

考虑下面的示例代码(我快速输入它作为示例,如果有错误也没关系-我对理论很感兴趣)。boolshutDown=false;//globalintmain(){CreateThread(NULL,0,&MessengerLoop,NULL,0,NULL);//dootherprogrammystuff...}DWORDWINAPIMessengerLoop(LPVOIDlpParam){zmq::context_tcontext(1);zmq::socket_tsocket(context,ZMQ_SUB);socket.connect("tcp://localhost:5556");so

c++ - 如何在不阻塞 UI 的情况下在 QGraphicsScene 中移动大约 1000 个项目

我的QGraphicsScene中有大约1000个图形项目。我想将所有这1000个项目移动到新位置。新职位互不相关,所有职位应同时完成。一种方法是遍历这1000个项目并为每个项目调用setPos!我认为这会阻止用户界面。另一种方法是在另一个线程中绘制图像并将此图像设置为QGraphicsScene中的结果!也许你有另一个想法。我很期待听到这个消息! 最佳答案 如果您了解Qt的工作原理,即使您想绘制1000条独立移动的鱼,Qt绘图也会非常快。在有大量项目的情况下,最糟糕的处理方式是为每个项目创建一个单独的QGraphicsItem/Q