草庐IT

ios - Swift 线程安全计数器变量？用于跟踪何时删除网络事件指示器

coder 2023-09-13 原文

我的场景的快速解释:

我有一个 iOS 应用程序，可以使用不同线程同时执行大量网络调用。在我的 iOS 应用程序中，我想在发生任何网络事件时显示内置的(在状态栏上)网络事件指示器。

所以我所做的是在任何网络调用之前启动事件指示器，然后在该网络调用出错或成功完成后停止它。

发生的事情(显然)是，一旦一个网络事件操作成功(或错误)完成，它就会删除网络事件指示器，即使我知道其他网络事件正在发生。

所以我的解决方案是创建一个静态变量(因为有很多类执行网络事件)，它跟踪当前正在执行的网络请求数量(每次启动时递增此静态变量，然后在它们启动时递减此静态变量完成(成功或失败)，仅当此计数器达到 0 时才会关闭网络事件指示器。

这工作正常，但是现在我们开始讨论我的问题 - 许多不同的线程正在更新这个静态变量，所以我认为它需要是线程安全的吗？

执行此操作的最佳方法是什么 - 我是否应该将每次启动/停止事件指示器(依次递增/递减静态变量)的调用放到主线程上，然后保证该变量将被读取/写入也是连续的？

或者我一直在阅读有关使用信号量告诉线程在变量被锁定时等待，然后在另一个线程完成对变量的读取和写入时运行的信息？

很抱歉问了这么长的问题，但我想向您介绍一下我目前的情况。

提前致谢

最佳答案

作为Sviatoslav Yakymiv said , 串行调度队列 可用于同步访问一个计数器，它保持 当前未完成的网络请求数。

可以为此目的使用 DispatchQueue.main 因为 UIApplication.shared.isNetworkActivityIndi​​catorVisible 只能是 无论如何都在主队列上访问。

最重要的是，计数器和网络指示器的管理 可以封装到一个类中 RAII -样的方式:

final public class NetworkActivity {

    private static var count = 0

    public init() {
        DispatchQueue.main.async {
            if NetworkActivity.count == 0 {
                UIApplication.shared.isNetworkActivityIndicatorVisible = true
            }
            NetworkActivity.count += 1
        }
    }

    deinit {
        DispatchQueue.main.async {
            NetworkActivity.count -= 1
            if NetworkActivity.count == 0 {
                UIApplication.shared.isNetworkActivityIndicatorVisible = false
            }
        }
    }
}

创建一个 NetworkActivity 实例增加全局计数器， 第一个实例使网络指示器可见。 销毁对象会减少计数器，并且指示器是 当最后一个实例被销毁时隐藏。

示例用法:

let request = URLRequest(...)
var activity: NetworkActivity? = NetworkActivity()
_ = activity // To suppress a "variable was written to, but never read" warning
let task = URLSession.shared.dataTask(with: request) { (data, response, error) in
    activity = nil
    // ...

}
task.resume()

关于ios - Swift 线程安全计数器变量？用于跟踪何时删除网络事件指示器，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/44864480/

何时SwiftNetworkActivitysectioncodeiosthread-safety

有关ios - Swift 线程安全计数器变量？用于跟踪何时删除网络事件指示器的更多相关文章

  1. ruby - RuntimeError(自动加载常量 Apps 多线程时检测到循环依赖 - 2

    我收到这个错误:RuntimeError(自动加载常量Apps时检测到循环依赖当我使用多线程时。下面是我的代码。为什么会这样？我尝试多线程的原因是因为我正在编写一个HTML抓取应用程序。对Nokogiri::HTML(open())的调用是一个同步阻塞调用，需要1秒才能返回，我有100,000多个页面要访问，所以我试图运行多个线程来解决这个问题。有更好的方法吗？classToolsController0)app.website=array.join(',')putsapp.websiteelseapp.website="NONE"endapp.saveapps=Apps.order("

  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 - 用 Ruby 编写一个简单的网络服务器 - 2

    我想在Ruby中创建一个用于开发目的的极其简单的Web服务器(不，不想使用现成的解决方案)。代码如下:#!/usr/bin/rubyrequire'socket'server=TCPServer.new('127.0.0.1',8080)whileconnection=server.acceptheaders=[]length=0whileline=connection.getsheaders想法是从命令行运行这个脚本，提供另一个脚本，它将在其标准输入上获取请求，并在其标准输出上返回完整的响应。到目前为止一切顺利，但事实证明这真的很脆弱，因为它在第二个请求上中断并出现错误:/usr/b

  5. ruby-on-rails - Ruby on Rails 计数器缓存错误 - 2

    尝试在我的RoR应用程序中实现计数器缓存列时出现错误Unknownkey(s):counter_cache。我在这个问题中实现了模型关联:Modelassociationquestion这是我的迁移:classAddVideoVotesCountToVideos0Video.reset_column_informationVideo.find(:all).eachdo|p|p.update_attributes:videos_votes_count,p.video_votes.lengthendenddefself.downremove_column:videos,:video_vot

  6. ruby - 使用多个数组创建计数 - 2

    我正在尝试按0-9和a-z的顺序创建数字和字母列表。我有一组值value_array=['0','1','2','3','4','5','6','7','8','9','a','b'，'光盘'，'e','f','g','h','i','j','k','l','m','n','o','p','q','r','s','','u','v','w','x','y','z']和一个组合列表的数组，按顺序，这些数字可以产生x个字符，比方说三个list_array=[]和一个当前字母和数字组合的数组(在将它插入列表数组之前我会把它变成一个字符串，]current_combo['0','0','0']

  7. ruby-on-rails - 有没有办法为 CarrierWave/Fog 设置上传进度指示器？ - 2

    我在Rails应用程序中使用CarrierWave/Fog将视频上传到AmazonS3。有没有办法判断上传的进度，让我可以显示上传进度如何？ 最佳答案 CarrierWave和Fog本身没有这种功能；你需要一个前端uploader来显示进度。当我不得不解决这个问题时，我使用了jQueryfileupload因为我的堆栈中已经有jQuery。甚至还有apostonCarrierWaveintegration因此您只需按照那里的说明操作即可获得适用于您的应用的进度条。 关于ruby-on-r

  8. 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使用的镜像网址默认为国外，下载容易超时，需要修改成国内镜像地址（首先阿里

  9. 网络编程套接字 - 2

    网络编程套接字网络编程基础知识理解源`IP`地址和目的`IP`地址理解源MAC地址和目的MAC地址认识端口号理解端口号和进程ID理解源端口号和目的端口号认识`TCP`协议认识`UDP`协议网络字节序socket编程接口`sockaddr``UDP`网络程序服务器端代码逻辑：需要用到的接口服务器端代码`udp`客户端代码逻辑`udp`客户端代码`TCP`网络程序服务器代码逻辑多个版本服务器单进程版本多进程版本多线程版本线程池版本服务器端代码客户端代码逻辑客户端代码TCP协议通讯流程TCP协议的客户端/服务器程序流程三次握手（建立连接）数据传输四次挥手（断开连接）TCP和UDP对比网络编程基础知识

  10. ruby - 如何让Ruby捕获线程中的语法错误 - 2

    我正在尝试使用ruby​​编写一个双线程客户端，一个线程从套接字读取数据并将其打印出来，另一个线程读取本地数据并将其发送到远程服务器。我发现的问题是Ruby似乎无法捕获线程内的错误，这是一个示例:#!/usr/bin/rubyThread.new{loop{$stdout.puts"hi"abc.putsefsleep1}}loop{sleep1}显然，如果我在线程外键入abc.putsef，代码将永远不会运行，因为Ruby将报告“undefinedvariableabc”。但是，如果它在一个线程内，则没有错误报告。我的问题是，如何让Ruby捕获这样的错误？或者至少，报告线程中的错误？

随机推荐