草庐IT

c++ - 在 Linux C++ 中终止阻塞 IO

coder 2023-06-21 原文

我正在使用多线程在 C++ 中的 Linux 上执行串行 IO。目前我正在使用阻塞读取。这让我无法停止阻塞 read() 中的线程咳嗽，除非强制终止或中断线程或使用 pthread 取消之类的东西。现在在整个网络上，我看到人们对建议他们需要从阻塞 IO 中终止线程的人大喊大叫。通常它与内存泄漏有关。只要您正确清理，线程中断是否会出现一些神奇的内存泄漏？ 

try
{
    while(true)
    {
        blocking_read(fd,buffer,512);
    }
}catch(interrupt_exception)
{

}
//clean up, close fd, release heap memory, usual stuff

或者我唯一的选择是像下面这样的东西还是实现更高级别的协议(protocol)以确保阻塞读取接收到签名输入使其能够自行关闭。

try
{
    while(running)
    {
        nonblocking_read(fd,buffer,512);

        if(cancel)
            running = false; //break return etc
    }
}

//clean up, close fd, release heap memory, usual stuff

再一次，如果你中断线程导致它抛出异常，在 read() 中是否会发生一些神奇的内存泄漏。

或者我应该根本不关心并让析构函数终止线程(我假设当您删除持有线程的对象时线程终止)？在那里打扫卫生？喜欢

class MyClass{
    int fd;    
    Thread* myThread;
    ~MyClass(){
        delete myThread;
        close(fd);
    }
};

感谢您的帮助!

最佳答案

read() 不应泄漏内存。对于阻塞和非阻塞读取，应用程序代码仍负责管理作为 buf 参数提供的内存。通过信号中断 read() 不会抛出异常，因此如果使用信号，您将需要检查结果和 errno。

  • 如果 read() 在读取数据之前被信号中断，将返回 -1 并将 errno 设置为 EINTR。
  • 如果 read() 在读取一些数据后被信号中断，POSIX 允许返回 -1 并将 errno 设置为 EINTR，或 read() 返回已读取的字节数。

如果您使用pthread_cancel()，则会抛出异常。使用这种方法，您有以下选择:

  • 通过使用 pthread_cleanup_push() 注册清理函数来执行清理。
  • 分配动态内存，通过pthread_setspecific()存储到线程特定存储。
  • 通过 auto_ptr/unique_ptr 管理内存。
  • 捕获 abi::__forced_unwind 异常，执行清理并重新抛出。

一般来说，要考虑避免线程取消。在可能的情况下，拥有一个用于跳出循环的共享标志会更好，也更易于管理。这允许线程执行任何必要的清理，并防止您的实现依赖于线程库的实现及其任何怪癖。

对于您使用阻塞读取的情况，请考虑轮询 fd 以查看数据是否可通过 select() 使用超时，并且仅调用 read() 如果 fd 有数据。这允许您定期检查线程标志是否设置为不再运行，并防止您需要处理信号以从 read() 中断线程，如 read() 不应再阻塞等待数据。

此外，删除线程对象时发生的行为取决于线程库。例如，删除 pthread_t 或 boost::thread 对关联线程的执行没有影响。

关于c++ - 在 Linux C++ 中终止阻塞 IO，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/10834469/

amp43codereadsectionc++linuxmultithreadingio

有关c++ - 在 Linux C++ 中终止阻塞 IO的更多相关文章

  1. ruby-on-rails - 如何优雅地重启 thin + nginx？ - 2

    我的瘦服务器配置了nginx，我的ROR应用程序正在它们上运行。在我发布代码更新时运行thinrestart会给我的应用程序带来一些停机时间。我试图弄清楚如何优雅地重启正在运行的Thin实例，但找不到好的解决方案。有没有人能做到这一点？ 最佳答案 #Restartjustthethinserverdescribedbythatconfigsudothin-C/etc/thin/mysite.ymlrestartNginx将继续运行并代理请求。如果您将Nginx设置为使用多个上游服务器，例如server{listen80;server

  2. ruby - 如何验证 IO.copy_stream 是否成功 - 2

    这里有一个很好的答案解释了如何在Ruby中下载文件而不将其加载到内存中:https://stackoverflow.com/a/29743394/4852737require'open-uri'download=open('http://example.com/image.png')IO.copy_stream(download,'~/image.png')我如何验证下载文件的IO.copy_stream调用是否真的成功——这意味着下载的文件与我打算下载的文件完全相同，而不是下载一半的损坏文件？documentation说IO.copy_stream返回它复制的字节数，但是当我还没有下

  3. Ruby 文件 IO 定界符？ - 2

    我正在尝试解析一个文本文件，该文件每行包含可变数量的单词和数字，如下所示:foo4.500bar3.001.33foobar如何读取由空格而不是换行符分隔的文件？有什么方法可以设置File("file.txt").foreach方法以使用空格而不是换行符作为分隔符？ 最佳答案 接受的答案将slurp文件，这可能是大文本文件的问题。更好的解决方案是IO.foreach.它是惯用的，将按字符流式传输文件:File.foreach(filename,""){|string|putsstring}包含“thisisanexample”结果的

  4. ruby - 使用 `+=` 和 `send` 方法 - 2

    如何将send与+=一起使用？a=20;a.send"+=",10undefinedmethod`+='for20:Fixnuma=20;a+=10=>30 最佳答案 恐怕你不能。+=不是方法，而是语法糖。参见http://www.ruby-doc.org/docs/ProgrammingRuby/html/tut_expressions.html它说Incommonwithmanyotherlanguages,Rubyhasasyntacticshortcut:a=a+2maybewrittenasa+=2.你能做的最好的事情是:

  5. Get https://registry-1.docker.io/v2/: net/http: request canceled while waiting - 2

    1.错误信息：Errorresponsefromdaemon:Gethttps://registry-1.docker.io/v2/:net/http:requestcanceledwhilewaitingforconnection(Client.Timeoutexceededwhileawaitingheaders)或者：Errorresponsefromdaemon:Gethttps://registry-1.docker.io/v2/:net/http:TLShandshaketimeout2.报错原因：docker使用的镜像网址默认为国外，下载容易超时，需要修改成国内镜像地址（首先阿里

  6. ruby - 如何计算 Liquid 中的变量 +1 - 2

    我对如何计算通过{%assignvar=0%}赋值的变量加一完全感到困惑。这应该是最简单的任务。到目前为止，这是我尝试过的:{%assignamount=0%}{%forvariantinproduct.variants%}{%assignamount=amount+1%}{%endfor%}Amount:{{amount}}结果总是0。也许我忽略了一些明显的东西。也许有更好的方法。我想要存档的只是获取运行的迭代次数。 最佳答案 因为{{incrementamount}}将输出您的变量值并且不会影响{%assign%}定义的变量，我

  7. ruby - 为什么不能使用类IO的实例方法noecho？ - 2

    print"Enteryourpassword:"pass=STDIN.noecho(&:gets)puts"Yourpasswordis#{pass}!"输出:Enteryourpassword:input.rb:2:in`':undefinedmethod`noecho'for#>(NoMethodError) 最佳答案 一开始require'io/console'后来的Ruby1.9.3 关于ruby-为什么不能使用类IO的实例方法noecho？，我们在StackOverflow上

  8. arrays - Ruby 数组 += vs 推送 - 2

    我有一个数组数组，想将元素附加到子数组。+=做我想做的，但我想了解为什么push不做。我期望的行为(并与+=一起工作):b=Array.new(3,[])b[0]+=["apple"]b[1]+=["orange"]b[2]+=["frog"]b=>[["苹果"],["橙子"],["Frog"]]通过推送，我将推送的元素附加到每个子数组(为什么？):a=Array.new(3,[])a[0].push("apple")a[1].push("orange")a[2].push("frog")a=>[[“苹果”、“橙子”、“Frog”]、[“苹果”、“橙子”、“Frog”]、[“苹果”、“

  9. += 的 Ruby 方法 - 2

    有没有办法让Ruby能够做这样的事情？classPlane@moved=0@x=0defx+=(v)#thisiserror@x+=v@moved+=1enddefto_s"moved#{@moved}times,currentxis#{@x}"endendplane=Plane.newplane.x+=5plane.x+=10putsplane.to_s#moved2times,currentxis15 最佳答案 您不能在Ruby中覆盖复合赋值运算符。任务在内部处理。您应该覆盖+，而不是+=。plane.a+=b与plane.a=

  10. ruby - Sinatra + Heroku + Datamapper 使用 dm-sqlite-adapter 部署问题 - 2

    出于某种原因，heroku尝试要求dm-sqlite-adapter，即使它应该在这里使用Postgres。请注意，这发生在我打开任何URL时-而不是在gitpush本身期间。我构建了一个默认的Facebook应用程序。gem文件:source:gemcuttergem"foreman"gem"sinatra"gem"mogli"gem"json"gem"httparty"gem"thin"gem"data_mapper"gem"heroku"group:productiondogem"pg"gem"dm-postgres-adapter"endgroup:development,:t

随机推荐