gauche thread-pool test

gauche-thread-pool-test.scm

#!/usr/bin/env gosh

(use control.thread-pool)

(define (log msg)
  (print (sys-time) ": " msg))

(log "start")

(define (run ls)
  (let* ((pool (make-thread-pool 5)))
    (begin
      (map (^n (add-job! pool
                         (lambda()
                           (begin
                             (log (list "at" n))
                             (sys-sleep 1)
                             ))))
           ls)
      (wait-all pool))))

(run '(1 2 3 4 5 6 7 8 9))

(log "finish")

$ gosh thread-pool-test.scm                                                        
1498526536: start
1498526536: (at 1)
1498526536: (at 3)
1498526536: (at 2)
1498526536: (at 4)
1498526536: (at 5)
1498526537: (at 6)
1498526537: (at 7)
1498526537: (at 9)
1498526537: (at 8)
1498526538: finish