Use Semaphore to avoid the internal queues grow infinitely.

zk1931 / jzab

ZooKeeper Atomic Broadcast in Java

http://zk1931.github.io/jzab/master/

Apache License 2.0

54 stars 23 forks source link

Use Semaphore to avoid the internal queues grow infinitely. #144

Closed EasonLiao closed 10 years ago

EasonLiao commented 10 years ago

Since the send are asynchronous, it's possible that the users keep sending stuff so the requests are accumulating in the various internal queues of Zab. Solve this by adding a Semaphore represents the maximum number of outstanding request to avoid this.

EasonLiao commented 10 years ago

@m1ch1