如何在球拍中並行映射一個函數？

Question

問題標題說明了這一切，真的：在球拍中並行映射函數的最佳方式是什麼？謝謝。

Answer 1

如果您的意思是在多個處理器內核上，那麼最一般的方法是使用Places。

場所支持開發利用多處理器，內核或硬件線程的機器的並行程序。

一個地方是一個並行任務，實際上是一個單獨的Racket虛擬機實例。地點通過地點信道進行通信，地點信道是用於雙向緩衝通信的端點。

您可能可以使用其他的並行化技術，Futures，但條件爲它工作都比較有限，例如浮點運算，如所描述here。

---

編輯：針對註釋：

是否有使用地方某處平行圖的實現？

首先，我應該備份。您可能不需要地點。使用Racket線程可以獲得併發性。例如，這裏有一個map/thread：

#lang racket 

(define (map/thread f xs) 
    ;; Make one channel for each element of xs. 
    (define cs (for/list ([x xs]) 
       (make-channel))) 
    ;; Make one thread for each elemnet of xs. 
    ;; Each thread calls (f x) and puts the result to its channel. 
    (for ([x xs] 
     [c cs]) 
    (thread (thunk (channel-put c (f x))))) 
    ;; Get the result from each channel. 
    ;; Note: This will block on each channel if not yet ready. 
    (for/list ([c cs]) 
    (channel-get c))) 

;; Use: 
(define xs '(1 2 3 4 5)) 
(map add1 xs) 
(map/thread add1 xs) 

如果正在開展的工作包括阻塞，例如I/O請求，這會給你「並行性」，因爲它不會停留在I/O上。但是Racket線程是「綠色」線程，因此一次只能使用一個CPU。

如果您真的需要並行使用多個CPU核心，那麼您需要Futures或Places。

由於地方的實施方式---有效地作爲球拍的多個實例---我不會立即看到如何編寫一個通用的map/place。對於使用在「定製」方式的地方示例，請參閱：

• Places in the Guide
• Places in the Reference

Answer 2

我不知道在拍，但我在SISC Scheme實施的版本。

(define (map-parallel fn lst) 
    (call-with-values (lambda() 
         (apply parallel 
          (map (lambda (e) 
            (delay (fn e))) 
            lst))) 
    list)) 

只有parallel不是R5RS。使用的

實施例：

使用正map：

(time (map (lambda (a) 
     (begin 
      (sleep 1000) 
      (+ 1 a))) 
    '(1 2 3 4 5))) 
=> ((2 3 4 5 6) (5000 ms)) 

使用map-parallel：

(time (map-parallel (lambda (a) 
     (begin 
      (sleep 1000) 
      (+ 1 a))) 
    '(1 2 3 4 5))) 
=> ((2 3 4 5 6) (1000 ms))