私は何を間違っていますか？よろしくお願いします。
データベースへのリクエストを制御する目的で次のコードを書きました。また、データベースを埋めるためにデータを解析しようとしていた外部 Web サイトへのリクエストも制御しました。目標は、1000 以上のリクエストを生成し、それらをスタックに置き、特定の時間に同時に発生するリクエストの数を制限することでした。これは非常にうまく機能しますが、次のコード行で例外が生成されることがよくあります。
RequestManager.requests?.append(_request!)
このコード行は、プッシュ関数 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)
}
}