сбой из-за `Lock.UnfairLock.lock()` при использовании `UIRefreshControl` при наблюдении за `Action.isExecuting`

Я использую UITableView для отображения списка с разбивкой на страницы, а UIRefreshControl — для указания того, что выполняется сетевой запрос.

Однако по какой-то причине self.refreshControl.beginRefreshing()/self.refreshControl.endRefreshing() вызывает сбой на os_unfair_lock_lock(_lock). Если я закомментирую обе эти строки, код будет работать нормально.

Для воспроизведения проблемы можно использовать следующий код:

import UIKit
import ReactiveSwift
import Result

class ViewController: UIViewController {

    @IBOutlet var tableView : UITableView!
    var refreshControl : UIRefreshControl!

    var i : Int = 0
    var action : Action<Int,[String],NoError>!
    var words = [String]()

    override func viewDidLoad() {
        super.viewDidLoad()

        tableView.delegate = self
        tableView.dataSource = self

        refreshControl = UIRefreshControl()
        tableView.addSubview(refreshControl)

        action = Action<Int,[String],NoError>{ pageNumber in
            return SignalProducer{ sink,_ in
                let deadlineTime = DispatchTime.now() + .seconds(2)
                DispatchQueue.main.asyncAfter(deadline: deadlineTime) {
                    if pageNumber == 1{
                        sink.send(value: ["Apple","Bananas","Clementines"])
                    }else if pageNumber == 2{
                        sink.send(value: ["Dodo","Eels","French"])
                    }
                    sink.sendCompleted()
                }
            }
        }

        action.values.observeValues { [weak self](moreWords) in
            if self?.words.isEmpty ?? true {
                self?.words = moreWords
            }else{
                self?.words.append(contentsOf: moreWords)
            }
            self?.tableView?.reloadData()
        }

         action.isExecuting.signal.observe(on: UIScheduler()).observeValues { [weak self](loading) in
            if loading{
                self?.refreshControl.beginRefreshing()
            }else{
                self?.refreshControl.endRefreshing()
            }
            print("loading \(loading)")
        }
    }
}

extension ViewController : UITableViewDataSource {

    public func tableView(_ tableView: UITableView, numberOfRowsInSection section: Int) -> Int{
        return self.words.count
    }

    public func tableView(_ tableView: UITableView, cellForRowAt indexPath: IndexPath) -> UITableViewCell{
        let identifier = "Whatever"
        var cell = tableView.dequeueReusableCell(withIdentifier: identifier)
        if cell == nil{
            cell = UITableViewCell(style: .default, reuseIdentifier: identifier)
        }
        cell!.textLabel?.text = self.words[indexPath.row]
        return cell!
    }
}

extension ViewController : UITableViewDelegate{
    func scrollViewDidScroll(_ scrollView: UIScrollView) {
        if (((scrollView.contentOffset.y + scrollView.frame.size.height) > scrollView.contentSize.height ) ){
           if !self.action.isExecuting.value {
                i += 1
                self.action.apply(i).start()
            }
        }
    }
}

person W.K.S    schedule 27.12.2017    source источник
comment
Вы пытались использовать код self?.refreshControl.beginRefreshing() & self?.refreshControl.endRefreshing() в основном потоке?   -  person Imad Ali    schedule 27.12.2017
comment
Интересно, что использование QueueScheduler.main вместо UIScheduler() решило проблему. Читая документацию, кажется, что это потому, что QueueScheduler.main сохраняет порядок, что, как я думаю, устраняет состояние гонки. Спасибо, не могли бы вы написать это как ответ, чтобы я мог его принять?   -  person W.K.S    schedule 27.12.2017


Ответы (2)


Используйте beginRefreshing и endRefreshing в основном потоке как:

QueueScheduler.main {
    if loading {
        self?.refreshControl.beginRefreshing()
    } else {
        self?.refreshControl.endRefreshing()
    }
}
person Imad Ali    schedule 27.12.2017

В моем случае у меня тоже произошел сбой в UnfairLock, но основная причина была другой. У меня была опечатка типа:

foo.bar <~ foo.bar.producer.skip(first: 1)

На самом деле я предполагал что-то вроде:

self.bar <~ foo.bar.producer.skip(first: 1)

Таким образом, попытайтесь найти самопривязки в вашем коде.

person Vladimir Vlasov    schedule 08.06.2018