Compare commits
2 commits
95200eccfd
...
3eba6fc820
| Author | SHA1 | Date | |
|---|---|---|---|
| 3eba6fc820 | |||
| d07e309566 |
2 changed files with 517 additions and 537 deletions
File diff suppressed because it is too large
Load diff
|
|
@ -1,9 +1,33 @@
|
|||
(use-modules (tests)
|
||||
(fibers)
|
||||
(fibers channels)
|
||||
(unit-test)
|
||||
(knots parallelism)
|
||||
(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
|
||||
(let ((val 0))
|
||||
(lambda ()
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue