Christopher Baines
016f37f108
Allow the thread pool to vary in size by basing it on a resource pool of fixed size thread pools, which are similar to the previous thread pool implementation. Fixed size thread pools don't require fibers, but thread pools now do. Some procedures work with either thread pool implementation.
88 lines
1.6 KiB
Scheme
88 lines
1.6 KiB
Scheme
(use-modules (tests)
|
|
(srfi srfi-71)
|
|
(fibers)
|
|
(unit-test)
|
|
(knots)
|
|
(knots thread-pool))
|
|
|
|
(let ((thread-pool
|
|
(make-fixed-size-thread-pool 2)))
|
|
|
|
(assert-equal
|
|
(call-with-thread
|
|
thread-pool
|
|
(lambda ()
|
|
4))
|
|
4))
|
|
|
|
(let ((thread-pool
|
|
(make-fixed-size-thread-pool
|
|
2
|
|
#:thread-initializer (const '(2)))))
|
|
|
|
(assert-equal
|
|
(call-with-thread
|
|
thread-pool
|
|
(lambda (num)
|
|
(* 2 num)))
|
|
4))
|
|
|
|
(let ((thread-pool
|
|
(make-fixed-size-thread-pool 2)))
|
|
|
|
(assert-equal
|
|
#t
|
|
(with-exception-handler
|
|
(lambda (exn)
|
|
(knots-exception? exn))
|
|
(lambda ()
|
|
(call-with-thread
|
|
thread-pool
|
|
(lambda ()
|
|
(+ 1 'a))))
|
|
#:unwind? #t)))
|
|
|
|
(run-fibers-for-tests
|
|
(lambda ()
|
|
(let ((thread-pool
|
|
(make-thread-pool 2)))
|
|
|
|
(assert-equal
|
|
(call-with-thread
|
|
thread-pool
|
|
(lambda ()
|
|
4))
|
|
4))))
|
|
|
|
(run-fibers-for-tests
|
|
(lambda ()
|
|
(let ((thread-pool
|
|
(make-thread-pool
|
|
2
|
|
#:thread-initializer (const '(2)))))
|
|
|
|
(assert-equal
|
|
(call-with-thread
|
|
thread-pool
|
|
(lambda (num)
|
|
(* 2 num)))
|
|
4))))
|
|
|
|
(run-fibers-for-tests
|
|
(lambda ()
|
|
(let ((thread-pool
|
|
(make-thread-pool 2)))
|
|
|
|
(assert-equal
|
|
#t
|
|
(with-exception-handler
|
|
(lambda (exn)
|
|
(knots-exception? exn))
|
|
(lambda ()
|
|
(call-with-thread
|
|
thread-pool
|
|
(lambda ()
|
|
(+ 1 'a))))
|
|
#:unwind? #t)))))
|
|
|
|
(display "thread-pool test finished successfully\n")
|