Почему я получаю ошибку UnsafeMutablePointer?

Question

Что я делаю неправильно? Заранее спасибо за помощь!!

Я написал следующий код с целью контроля запросов к моей базе данных, а также к внешнему веб-сайту, который я пытался проанализировать для его данных, чтобы я мог заполнить свою базу данных. Цель состояла в том, чтобы сгенерировать более 1000 запросов, поместить их в стек, а затем ограничить количество одновременных запросов в определенный момент времени. Он работает очень хорошо, но время от времени он генерирует исключение в этой строке кода:

RequestManager.requests?.Append(_REQUEST!)

Эта строка кода находится в функции Push WebRequestManager. Вы можете увидеть код ниже.

фатальная ошибка: UnsafeMutablePointer.destroy с отрицательным числом

Пример запроса выглядит так:

WebRequestManager.Request(WebRequest(_data: self.beerstores, _url: "http://brewskibooze.com/beerstore/build_database/postbeerstoreproductavailability.php"),
                                    completion: {
                                        (data,response,error) in
                                        if error == nil
                                        {
                                            self.display(_string: "Process Complete")
                                        }
                                        else
                                        {
                                            self.display(_string: "Unable to post inventory.")
                                        }


                                    })

Вот код:

class WebRequest

{

private var trials = 0

private var executed  = false

private var data : AnyObject?

private var url : String?

private var completion : ((data: NSData?, response: NSURLResponse?, error : ErrorType?) -> Void)?

private func execute()
{
    if !executed
    {
        trials += 1
        self.executed = true
        let endpoint = NSURL(string: url!)

        if (endpoint == nil) { return }

        let request = NSMutableURLRequest(URL: endpoint!)

        if data != nil
        {
            if data is NSData
            {
                request.HTTPMethod = "POST"
                request.HTTPBody = data as? NSData
            }
            else
            {
                request.HTTPMethod = "POST"
                request.HTTPBody = try! NSJSONSerialization.dataWithJSONObject(data!, options: [])
            }
        }
        request.addValue("application/json", forHTTPHeaderField: "Content-Type")
        request.addValue("application/json", forHTTPHeaderField: "Accept")

        let task = NSURLSession.sharedSession().dataTaskWithRequest(request)
        {
            data, response, error in

            if error == nil
            {

                WebRequestManager.pop()

                self.completion?(data: data,response: response,error: error)
            }
            else
            {
                if self.trials < 10
                {
                    self.executed = false
                    self.execute()
                }
                else
                {
                    WebRequestManager.pop()
                    self.completion?(data: data,response: response,error: error)
                }
            }
        }
        task.resume()
    }
}

init(_query : Query?)
{

    data = _query!.data

    url = _query!.toString()
}

init(_data : AnyObject?, _url : String)
{

    data = _data

    url = _url
}

init(_data : NSData?, _url : String)
{
    data = _data
    url = _url
}

deinit
{
    completion = nil
    data = nil
    url = nil
}

}

class WebRequestManager

{

private var requests : [WebRequest]?
private static var MaxConcurrentRequests = 10

private var currentRequestCount = 0

private static var RequestManager = WebRequestManager()

private class var RequestCount : Int
{
    return RequestManager.currentRequestCount
}

private class func DecrementCount()
{
    RequestManager.currentRequestCount -= 1
}

private class func IncrementCount()
{
    RequestManager.currentRequestCount += 1
}

private class func push(_request : WebRequest?)
{
    if _request != nil
    {
        IncrementCount()
        RequestManager.requests?.append(_request!)
    }

}

private class func pop()
{
    if RequestManager.requests?.count > 0
    {
        let last : WebRequest? = RequestManager.requests?.removeLast()
        if last != nil
        {
            last!.execute()
            DecrementCount()
        }
    }
}

init()
{
    requests = [WebRequest]()
}

class var ActiveThreadCount : Int
{
    return RequestManager.currentRequestCount
}


class func Request(_request : WebRequest?,completion : ((data: NSData?, response: NSURLResponse?, error : ErrorType?) -> Void)?)
{
    _request?.completion = completion
    if RequestCount < MaxConcurrentRequests
    {
        _request?.execute()
    }
    push(_request)
}

}

Answer 1

Вы указали мне правильное направление, очередь с последовательной рассылкой разрешила мою проблему без предупреждений.

Создайте очередь последовательной отправки в swift 3:

    let serialQueue = DispatchQueue(label: "myqueue")`

Затем измените массив в очереди:

    serialQueue.sync {
        //modify array
    }

Answer 2

Я уверен, я просто ответил на свой вопрос. Проблема заключается в том, что при всех этих многочисленных запросах и множестве всплывающих и отправляемых запросов в многопоточной среде существует риск одновременного всплывающего и толкающего запросов. Решение выглядит так:

objc_sync_enter (замок)

objc_sync_exit (замок)

Кредит здесь:

Создать потокобезопасный массив в Swift

Но это вызывает это предупреждение...

| синхронизировать пропуска | внутри блока моментальных снимков был запущен забор - пропуск рабочей области синхронизируется, поскольку он может исключить из очереди сообщения из fenceExemptQueue, а моментальные снимки ожидают, что этого не произойдет 2016-05-14 14: 11: 57.791 _____ [348: 99565] | synchronize-skip | внутри блока снимка был запущен забор - пропускается синхронизация рабочего пространства, поскольку он может исключить сообщения из fenceExemptQueue, и снимки ожидают, что этого не произойдет