core.async 파이프 라인의 병렬 처리 인수의 의미와 목적은 무엇입니까?

Question

core.async에는 pipelines의 세 가지 종류가 있습니다. pipeline, pipeline-blocking 및 pipeline-async입니다. 이 함수의 첫 번째 인수는 파이프 라인의 '병렬 처리'인 n입니다.

이 인수의 의미는 무엇입니까?

각 파이프 라인 유형에 어떤 영향을 미칩니 까? 병렬성에 적합한 기본 값은 무엇입니까? 언제, 왜 그 값을 늘리거나 줄일 것입니까? 실행중인 프로그램에 이러한 파이프 라인이 여러 개 있으면 어떻게 될까요?

Answer 1

The source는 정보입니다 :

여기

(dotimes [_ n] 
    (case type 
      :blocking (thread 
         (let [job (<!! jobs)] 
         (when (process job) 
          (recur)))) 
      :compute (go-loop [] 
           (let [job (<! jobs)] 
           (when (process job) 
            (recur)))) 
      :async (go-loop [] 
          (let [job (<! jobs)] 
           (when (async job) 
           (recur)))))) 

n가 제공하는 병렬 인수입니다; (블로킹 모드에서) 또는 go-loop (컴퓨팅 또는 비동기 모드에서)의 수를 제어합니다.

"양호한 기본값"을 구성하는 것은로드 프로필, 하드웨어 리소스, &에 따라 다릅니다. c - 네트워크 액세스로 인해 작업이 차단되는 경우 CPU가있는 것보다 더 많은 작업이있을 수 있으며 차단되는 경우 CPU를 사용할 수 있기를 기대하는 코어보다 많은 스레드는 낭비입니다. 병목 현상이 로컬 디스크 I/O 인 경우이 질문의 범위를 훨씬 뛰어 넘는 많은 세부 사항 (플래터 또는 NVRAM 회전 - 다른 프로세스의 액세스 요구 사항이 플래터를 통해 분산되어 있습니까?)이 관련성이 있습니다.

일반적으로 스레드 풀 사이징에 일반적으로 적용 할 판단, 경험 및 튜닝/측정 기술을 사용하십시오.