diff options
| author | Robert Greig <rgreig@apache.org> | 2007-02-01 10:18:36 +0000 |
|---|---|---|
| committer | Robert Greig <rgreig@apache.org> | 2007-02-01 10:18:36 +0000 |
| commit | c1d55b07f5f900f8cc46bb8814da03d1fa00adb6 (patch) | |
| tree | b572f0134a4d58f5fa4cb2e72532398e42329d24 /qpid/java/perftests/src | |
| parent | b12db1a36b5d01992b794534cf016189d35efc19 (diff) | |
| download | qpid-python-c1d55b07f5f900f8cc46bb8814da03d1fa00adb6.tar.gz | |
(Submitted by Rupert Smith) Added comments as a reminder of improvements to be made to the tests.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@502182 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/perftests/src')
| -rw-r--r-- | qpid/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java b/qpid/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java index c212d3a0e7..7c5bb92a57 100644 --- a/qpid/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java +++ b/qpid/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java @@ -87,7 +87,8 @@ import uk.co.thebadgerset.junit.extensions.Throttle; * @todo Use read/write lock in the onmessage, not for reading writing but to make use of a shared and exlcusive lock
* pair. Obtian read lock on all messages, before decrementing the message count. At the end of the on message
* method add a block that obtains the write lock for the very last message, releases any waiting producer. Means
- * that the last message waits until all other messages have been handled before releasing producers.
+ * that the last message waits until all other messages have been handled before releasing producers but allows
+ * messages to be processed concurrently, unlike the current synchronized block.
*
* @todo Set the timeout to be per message correlation id. Restart it every time a message is received (with matching id).
* Means that timeout is measuring situations whether a particular ping stream has pasued for too long, rather than
|