草庐IT

ios - dispatch_queue_set_specific 与获取当前队列

coder 2023-09-22 原文

我试图弄清楚这两者之间的区别和用法:

static void *myFirstQueue = "firstThread";

dispatch_queue_t firstQueue = dispatch_queue_create("com.year.new.happy", DISPATCH_QUEUE_CONCURRENT);

dispatch_queue_set_specific(firstQueue, myFirstQueue, (void*) myFirstQueue, NULL);

问题 #1

这有什么区别:
dispatch_sync(firstQueue, ^{

    if(dispatch_get_specific(myFirstQueue))
    {
        //do something here
    }
});

以及以下内容:
dispatch_sync(firstQueue, ^{

    if(firstQueue == dispatch_get_current_queue())
    {
       //do something here
    }
});

?

问题 #2:

而不是使用上面的(void*) myFirstQueue
dispatch_queue_set_specific(firstQueue, myFirstQueue, (void*) myFirstQueue, NULL);

我们可以使用 static int * myFirstQueue = 0;反而 ?

我的推理基于以下事实:
dispatch_once_t也是 0 (这里有什么相关性吗?顺便说一句,我仍然不太明白为什么 dispatch_once_t 必须初始化为 0,尽管我已经阅读了关于 SO 的问题)。

问题 #3

你能在这里举一个 GCD 死锁的例子吗?

问题 #4

这可能有点过分了。无论如何,我会问,以防有人碰巧知道这一点。如果没有,可以不回答这部分。

这个我没试过,因为我真的不知道怎么做。但我的概念是这样的:

无论如何,我们是否可以在某个队列中“放置一个句柄”,使我们仍然能够保留一个句柄,从而能够检测到队列分离后何时发生死锁;当存在时,并且由于我们获得了之前设置的队列句柄,我们可以以某种方式做一些事情来解锁死锁吗?

同样,如果这个回答太多,或者我的推理在此处完全不可撤销/关闭(在 问题 #4 中),请随时不要回答这部分。

新年快乐。

@san.t

static void *myFirstQueue = 0;
我们这样做:
dispatch_queue_set_specific(firstQueue, &myFirstQueue, &myFirstQueue, NULL);

完全可以理解。

但如果我们这样做:
static void *myFirstQueue = 1; 
//or any other number other than 0, it would be OK to revert back to the following?
dispatch_queue_set_specific(firstQueue, myFirstQueue, (void*) myFirstQueue, NULL);

关于 dispatch_once_t :

您能否详细说明一下:

为什么一定要dispatch_once_t首先是 0 ,以及它如何以及为什么需要在后期充当 bool 值?这是否与内存/安全性或先前的内存地址被其他不为 0 的对象( nil )占用的事实有关?

至于问题#3:

抱歉,我可能不太清楚:我并不是说我遇到了僵局。我的意思是是否有人可以向我展示导致死锁的 GCD 代码场景。

最后:

希望你能回答问题#4。如果没有,如前所述,没关系。

最佳答案

首先,我真的不认为您打算使该队列并发。 dispatch_sync()连接到并发队列并不能真正完成任何事情(并发队列不保证在其上运行的 block 之间的顺序)。所以,这个答案的其余部分假设你打算在那里有一个串行队列。另外,我将笼统地回答这个问题,而不是您的具体问题;希望没关系:)

使用 dispatch_get_current_queue() 有两个基本问题这边走。一个非常广泛的可以概括为“递归锁定是一个坏主意”,另一个可以概括为“您可以并且经常会有多个当前队列”的调度特定的。

问题 #1:递归锁定是个坏主意

私有(private)串行队列的通常用途是 保护代码的不变量 (“不变”是“必须是真实的东西”)。例如,如果您使用队列来保护对属性的访问以使其是线程安全的,则不变量是“此属性没有无效值”(例如:如果属性是结构,则一半如果同时从两个线程设置结构,则结构可以有一个新值,一半可以有旧值。串行队列强制一个线程或另一个线程在另一个线程开始之前完成整个结构的设置)。

我们可以推断,为了使这一点有意义,当开始执行串行队列上的 block 时,不变量必须保持不变(否则,它显然没有受到保护)。一旦 block 开始执行,它就可以打破不变量(例如,设置属性)而不必担心弄乱任何其他线程,只要不变量在它返回时再次保持(在这个例子中,属性必须完全放)。

总结只是为了确保您仍在关注:在串行队列上每个 block 的开始和结束处,队列所保护的不变量必须保持。在每个 block 的中间,它可能会被打破。

如果在 block 内部,您调用了试图使用受队列保护的东西的东西,那么您已经将这个简单的规则更改为更复杂的规则:而不是“在每个 block 的开头和结尾”它是“ 在开始、结束以及该 block 调用自身外部的任何点 "。换句话说,您现在必须检查 ,而不是在 block 级别考虑线程安全。每一行 每个 block 的。

这和 dispatch_get_current_queue() 有什么关系? ?使用 dispatch_get_current_queue() 的唯一理由这里是检查“我们已经在这个队列中了吗?”,如果您已经在当前队列中,那么您已经处于上述可怕的情况!所以不要那样做。使用私有(private)队列来保护事物,不要从它们内部调用其他代码。您应该已经知道“我在这个队列中吗?”的答案。它应该是“不”。

这是最大的原因dispatch_get_current_queue()已弃用:阻止人们尝试用它来模拟递归锁定(我上面已经描述过)。

问题 #2:您可以拥有多个当前队列!

考虑这段代码:

dispatch_async(queueA, ^{
    dispatch_sync(queueB, ^{
        //what is the current queue here?
    });
});

显然 queueB 是当前的,但我们还在 queueA 上! dispatch_sync导致 queueA 上的工作等待 queueB 上的工作完成,因此它们实际上都是“当前的”。

这意味着这段代码会死锁:
dispatch_async(queueA, ^{
    dispatch_sync(queueB, ^{
        dispatch_sync(queueA, ^{});
    });
});

您还可以使用目标队列来拥有多个当前队列:
dispatch_set_target_queue(queueB, queueA);
dispatch_sync(queueB, ^{
    dispatch_sync(queueA, ^{ /* deadlock! */ });
});

这里真正需要的是一个假设的“dispatch_queue_is_synchronous_with_queue(queueA, queueB)”,但因为这仅对实现递归锁定有用,而且我已经描述了这是一个坏主意……不太可能添加。

请注意,如果您只使用 dispatch_async() ,那么你就不会出现死锁。可悲的是,您根本无法免受比赛条件的影响。

关于ios - dispatch_queue_set_specific 与获取当前队列,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/20860997/

有关ios - dispatch_queue_set_specific 与获取当前队列的更多相关文章

  1. ruby-on-rails - 如何使用 instance_variable_set 正确设置实例变量? - 2

    我正在查看instance_variable_set的文档并看到给出的示例代码是这样做的:obj.instance_variable_set(:@instnc_var,"valuefortheinstancevariable")然后允许您在类的任何实例方法中以@instnc_var的形式访问该变量。我想知道为什么在@instnc_var之前需要一个冒号:。冒号有什么作用? 最佳答案 我的第一直觉是告诉你不要使用instance_variable_set除非你真的知道你用它做什么。它本质上是一种元编程工具或绕过实例变量可见性的黑客攻击

  2. ruby - 简单获取法拉第超时 - 2

    有没有办法在这个简单的get方法中添加超时选项?我正在使用法拉第3.3。Faraday.get(url)四处寻找,我只能先发起连接后应用超时选项,然后应用超时选项。或者有什么简单的方法?这就是我现在正在做的:conn=Faraday.newresponse=conn.getdo|req|req.urlurlreq.options.timeout=2#2secondsend 最佳答案 试试这个:conn=Faraday.newdo|conn|conn.options.timeout=20endresponse=conn.get(url

  3. 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返回它复制的字节数,但是当我还没有下

  4. ruby - 从 Ruby 中的主机名获取 IP 地址 - 2

    我有一个存储主机名的Ruby数组server_names。如果我打印出来,它看起来像这样:["hostname.abc.com","hostname2.abc.com","hostname3.abc.com"]相当标准。我想要做的是获取这些服务器的IP(可能将它们存储在另一个变量中)。看起来IPSocket类可以做到这一点,但我不确定如何使用IPSocket类遍历它。如果它只是尝试像这样打印出IP:server_names.eachdo|name|IPSocket::getaddress(name)pnameend它提示我没有提供服务器名称。这是语法问题还是我没有正确使用类?输出:ge

  5. ruby - 获取模块中定义的所有常量的值 - 2

    我想获取模块中定义的所有常量的值:moduleLettersA='apple'.freezeB='boy'.freezeendconstants给了我常量的名字:Letters.constants(false)#=>[:A,:B]如何获取它们的值的数组,即["apple","boy"]? 最佳答案 为了做到这一点,请使用mapLetters.constants(false).map&Letters.method(:const_get)这将返回["a","b"]第二种方式:Letters.constants(false).map{|c

  6. ruby-on-rails - 获取 inf-ruby 以使用 ruby​​ 版本管理器 (rvm) - 2

    我安装了ruby​​版本管理器,并将RVM安装的ruby​​实现设置为默认值,这样'哪个ruby'显示'~/.rvm/ruby-1.8.6-p383/bin/ruby'但是当我在emacs中打开inf-ruby缓冲区时,它使用安装在/usr/bin中的ruby​​。有没有办法让emacs像shell一样尊重ruby​​的路径?谢谢! 最佳答案 我创建了一个emacs扩展来将rvm集成到emacs中。如果您有兴趣,可以在这里获取:http://github.com/senny/rvm.el

  7. Ruby 文件 IO 定界符? - 2

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

  8. Ruby 从大范围中获取第 n 个项目 - 2

    假设我有这个范围:("aaaaa".."zzzzz")如何在不事先/每次生成整个项目的情况下从范围中获取第N个项目? 最佳答案 一种快速简便的方法:("aaaaa".."zzzzz").first(42).last#==>"aaabp"如果出于某种原因你不得不一遍又一遍地这样做,或者如果你需要避免为前N个元素构建中间数组,你可以这样写:moduleEnumerabledefskip(n)returnto_enum:skip,nunlessblock_given?each_with_indexdo|item,index|yieldit

  9. ruby - Net::HTTP 获取源代码和状态 - 2

    我目前正在使用以下方法获取页面的源代码:Net::HTTP.get(URI.parse(page.url))我还想获取HTTP状态,而无需发出第二个请求。有没有办法用另一种方法做到这一点?我一直在查看文档,但似乎找不到我要找的东西。 最佳答案 在我看来,除非您需要一些真正的低级访问或控制,否则最好使用Ruby的内置Open::URI模块:require'open-uri'io=open('http://www.example.org/')#=>#body=io.read[0,50]#=>"["200","OK"]io.base_ur

  10. ruby - 分布式事务和队列,ruby,erlang,scala - 2

    我有一个涉及多台机器、消息队列和事务的问题。因此,例如用户点击网页,点击将消息发送到另一台机器,该机器将付款添加到用户的帐户。每秒可能有数千次点击。事务的所有方面都应该是容错的。我以前从未遇到过这样的事情,但一些阅读表明这是一个众所周知的问题。所以我的问题。我假设安全的方法是使用两阶段提交,但协议(protocol)是阻塞的,所以我不会获得所需的性能,我是否正确?我通常写Ruby,但似乎Redis之类的数据库和Rescue、RabbitMQ等消息队列系统对我的帮助不大——即使我实现某种两阶段提交,如果Redis崩溃,数据也会丢失,因为它本质上只是内存。所有这些让我开始关注erlang和

随机推荐