Tasks #1438
Use lparallel queues instead of sb-concurrency queues
Status: | Resolved | Start date: | 02/26/2013 | |
---|---|---|---|---|
Priority: | Normal | Due date: | ||
Assignee: | J. Moringen | % Done: | 100% | |
Category: | Common Lisp | |||
Target version: | rsb-0.9 |
Associated revisions
Use lparallel queues, atomic-inc instead of sb-concurrency
fixes #1438
- src/util.lisp (header): updated copyright
(make-sequence-number-generator): use lparallel.counter when
possible - src/transport/inprocess/in-pull-connector.lisp (header): updated
copyright
(in-pull-connector::queue): use `lparallel.queue:queue'
(in-pull-connector::lock): removed
(in-pull-connector::condition): likewise
(connector-queue-count in-pull-connector): removed
(handle in-pull-connector event): use `lparallel.queue:queue'
unconditionally
(receive-message in-pull-connector eql nil): likewise
(receive-message in-pull-connector t): likewise
(print-object in-pull-connector t): use
`lparallel.queue:queue-count' instead of `connector-queue-count' - src/transport/socket/in-pull-connector.lisp (header): updated
copyright
(in-pull-connector::queue): use `lparallel.queue:queue'
(connector-queue-count in-pull-connector): removed
(handle in-pull-connector notification): use `lparallel.queue:queue'
unconditionally
(receive-message in-pull-connector eql nil): likewise
(receive-message in-pull-connector t): likewise
(print-object in-pull-connector t): use
`lparallel.queue:queue-count' instead of `connector-queue-count' - cl-rsb.asd (system cl-rsb): added system dependency on lparallel;
removed system dependency on sb-concurrency
Use lparallel queues, atomic-inc instead of sb-concurrency
fixes #1438
- src/util.lisp (header): updated copyright
(make-sequence-number-generator): use lparallel.counter when
possible - src/transport/inprocess/in-pull-connector.lisp (header): updated
copyright
(in-pull-connector::queue): use `lparallel.queue:queue'
(in-pull-connector::lock): removed
(in-pull-connector::condition): likewise
(connector-queue-count in-pull-connector): removed
(handle in-pull-connector event): use `lparallel.queue:queue'
unconditionally
(receive-message in-pull-connector eql nil): likewise
(receive-message in-pull-connector t): likewise
(print-object in-pull-connector t): use
`lparallel.queue:queue-count' instead of `connector-queue-count' - src/transport/socket/in-pull-connector.lisp (header): updated
copyright
(in-pull-connector::queue): use `lparallel.queue:queue'
(connector-queue-count in-pull-connector): removed
(handle in-pull-connector notification): use `lparallel.queue:queue'
unconditionally
(receive-message in-pull-connector eql nil): likewise
(receive-message in-pull-connector t): likewise
(print-object in-pull-connector t): use
`lparallel.queue:queue-count' instead of `connector-queue-count' - cl-rsb.asd (system cl-rsb): added system dependency on lparallel;
removed system dependency on sb-concurrency
Use lparallel queue in src/rsb/replay/remote-controlled.lisp
refs #1438
- src/rsb/replay/remote-controlled.lisp (remote-controlled::queue):
use `lparallel.queue:queue' instead of `sb-concurrency:mailbox'
(enqueue remote-controlled t): likewise
(next-command remote-controlled): likewise
History
#1 Updated by J. Moringen about 11 years ago
- Status changed from New to Resolved
- % Done changed from 0 to 100
Applied in changeset rsb-cl|commit:4dd668c5018459560abde103683f4d8aeea4f6c7.