Fcalva/cyclone
1
0
Fork 0
mirror of https://github.com/justinethier/cyclone.git synced 2025-07-15 16:57:35 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

WIP

Browse source
This commit is contained in:
Justin Ethier 2019-06-27 18:38:39 -04:00
parent 5025ce04e6
commit f257c78aba
1 changed files with 14 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
libs/cyclone/shared-queue.sld
View file

@ -40,7 +40,7 @@
thread-pool-size thread-pool-size
thread-pool-idling-count thread-pool-idling-count
thread-pool-idling? thread-pool-idling?
; thread-pool-push-task! thread-pool-push-task!
; ;;thread-pool-wait-all! ; ;;thread-pool-wait-all!
; ;;thread-pool-release! ; ;;thread-pool-release!
) )
@ -199,11 +199,10 @@
(define-record-type <thread-pool> (define-record-type <thread-pool>
(%make-thread-pool jobq threads num-threads ) (%make-thread-pool jobq threads )
thread-pool? thread-pool?
(jobq tp:jobq tp-set-jobq!) (jobq tp:jobq tp-set-jobq!)
(threads tp:threads tp:set-threads!) (threads tp:threads tp:set-threads!)
(num-threads tp:num-threads tp:set-num-threads!)
) )
(define (default-handler err) #f) (define (default-handler err) #f)
@ -212,17 +211,23 @@
(lambda () (lambda ()
(let loop () (let loop ()
(with-handler (with-handler
default-handler ;; TODO: allow passing this in (lambda (e)
(write `(error ,e))
(newline)
)
; default-handler ;; TODO: allow passing this in
(let ((thunk (queue-remove! q))) (let ((thunk (queue-remove! q)))
(thunk)) (thunk))
))))) )
(loop)
))))
(define (make-thread-pool size) (define (make-thread-pool size) ;; TODO: optional exception handler
(let ((tp (%make-thread-pool (make-queue) '() size))) (let ((tp (%make-thread-pool (make-queue) '() size)))
(do ((i size (- i 1))) (do ((i size (- i 1)))
((zero? i)) ((zero? i))
(let ((t (%make-thread-pool-thread (tp:jobq tp)))) (let ((t (%make-thread-pool-thread (tp:jobq tp))))
(tp:set-threads! (cons t (tp:threads))) (tp:set-threads! tp (cons t (tp:threads tp)))
(thread-start! t))) (thread-start! t)))
(share-all!) (share-all!)
tp)) tp))
@ -236,7 +241,8 @@
(define (thread-pool-idling? tp) (define (thread-pool-idling? tp)
(> (thread-pool-idling-count tp) 0)) (> (thread-pool-idling-count tp) 0))
; TODO: thread-pool-push-task! (define (thread-pool-push-task! tp thunk)
(queue-add! (tp:jobq tp) (make-shared thunk)))
; ?? - thread-pool-wait-all! ; ?? - thread-pool-wait-all!