cbaines/guile-knots
1
Fork 0
Code Issues Pull requests Activity Actions

Compare commits

base: cbaines:3eba6fc8209f254b8068459a59d0056a629528d9
Branches Tags
cbaines:trunk
cbaines:pages
cbaines:actions-test
..
compare: cbaines:95200eccfd5668fa94a0dfad6eab93d7b7731c9d
Branches Tags
cbaines:trunk
cbaines:pages
cbaines:actions-test

No commits in common. "3eba6fc8209f254b8068459a59d0056a629528d9" and "95200eccfd5668fa94a0dfad6eab93d7b7731c9d" have entirely different histories.
3eba6fc820 ... 95200eccfd

2 changed files with 537 additions and 517 deletions
Download patch file Download diff file Expand all files Collapse all files

844
knots/resource-pool.scm
View file

File diff suppressed because it is too large Load diff

24
tests/resource-pool.scm
View file

@ -1,33 +1,9 @@
(use-modules (tests) (use-modules (tests)
(fibers) (fibers)
(fibers channels)
(unit-test) (unit-test)
(knots parallelism) (knots parallelism)
(knots resource-pool)) (knots resource-pool))
(run-fibers-for-tests
(lambda ()
(let ((parallelism-limiter (make-parallelism-limiter
1)))
(with-parallelism-limiter parallelism-limiter
#f)
(destroy-parallelism-limiter parallelism-limiter))))
(run-fibers-for-tests
(lambda ()
(let ((parallelism-limiter (make-parallelism-limiter
1))
(channel
(make-channel)))
(spawn-fiber
(lambda ()
(with-parallelism-limiter parallelism-limiter
(put-message channel #t)
(sleep 1))))
(get-message channel)
(destroy-parallelism-limiter parallelism-limiter))))
(define new-number (define new-number
(let ((val 0)) (let ((val 0))
(lambda () (lambda ()