스위프트 4 : 이초과 비동기식 시리얼 큐 만들기 ... 각 작업

Question

유무 문제가이 문제를 시각화했다 후 대기 시간

는 내가 2 개 스레드를 필요로하고이를 구현하는 방법을 잘 모르겠습니다 생각합니다.

각 네트워크 검색 요청이 완료된 후 최소 2 초의 지연이 필요합니다.

메인 스레드 :

있는 UIButton을 누르면 -> 기능 직렬 큐에 네트워크 검색 요청을 추가 -> UILoop 계속 ...

네트워크 스레드 : 다음 요청

확인 큐 -> 요청 시작 -> 요청 완료 -> 2 초 대기 -> 다음 요청 대기열 확인 -> 요청 시작 -> 요청 완료 -> 2 초 대기 -> 다음 요청 대기열 확인 - > 요청 없음 -> 다음 요청에 대한 대기열을 확인합니다 ... 또는 호출 될 때까지 루프를 종료합니다.

var networkQueue = [NetworkRequest]() 
var networkQueueActive = false 

@IBAction func buttonPressed(_ sender: UIButton) { 
    networkQueue.append(NetworkRequest(UIButton)) 
    if networkQueueActive == false { 
     networkRetrieveFromQueue() // need to asynchronously call this DON'T KNOW HOW TO DO THIS 
    } 
} 

func networkRetrieveFromQueue() { 
    networkQueueActive = true 
    while !networkQueue.isEmpty { 
     let request = networkQueue.remove(at: 0) 
     // synchronous network data retrieval on this thread KNOW HOW TO DO THIS 
     // do something with the data retrieved KNOW HOW TO DO THIS 
     // wait 2 seconds DON'T KNOW HOW TO DO THIS 
    } 
    networkQueueActive = false 
} 

Answer 1

당신이 그런

var networkQueue = [NetworkRequest]() 
var networkQueueActive = false 

이 있으면 networkRetrieveFromQueue해야 : 큐가 비어있는 경우

• 검사를 참조하십시오;
• 그렇지 않으면 대기열의 첫 번째 항목을 가져옵니다.
• 비동기 요청을 시작합니다.

  // perform asynchronous network request, with completion handler that is 
  // called when its done 
  
  func get(request: NetworkRequest, completionHandler: @escaping() -> Void) { 
      let task = URLSession.shared.dataTask(with: request.request) { data, _, error in 
       guard let data = data, error == nil else { 
        print(error ?? "Unknown error") 
        completionHandler() 
        return 
       } 
  
       // process successful response here 
  
       // when done, call completion handler 
  
       completionHandler() 
      } 
      task.resume() 
  } 
  

  : 및

그 비동기 요청이 완료 핸들러에서
• , 어디 "프로세스 요청"처럼 보일 수 있습니다 이초 따라서

func startQueue() { 
    if networkQueueActive { return } 

    networkQueueActive = true 
    processNext() 
} 

// if queue not empty, grab first item, perform request, and call itself 
// 2 seconds after prior one finishes 

func processNext() { 
    if networkQueue.isEmpty { 
     networkQueueActive = false 
     return 
    } 

    let request = networkQueue.removeFirst() 

    get(request: request) { 
     DispatchQueue.main.asyncAfter(deadline: .now() + 2) { 
      self.processNext() 
     } 
    } 
} 

후 다시 networkRetrieveFromQueue 전화 자, 당신의 NetworkRequest이 어떻게 생겼는지는 모르겠지만, 이것은 재귀 적으로 t에서 함수를 호출하는 방법에 대한 기본적인 아이디어를 보여줍니다. 일부 비동기 메소드의 완료 핸들러.