Print this page
4719 Common patchset for jdk1.7 support preparation
*** 635,645 ****
synchronized (stopLock) {
// Notify listeners while holding stopLock to guarantee
// that listeners finish executing consumerStopped()
// before the stop() method returns.
synchronized (this) {
! if (state == State.STOPPED || state == state.CLOSED) {
//
// This consumer was stopped just after calling
// go() but before starting (the premature return
// case at the top of this work() method). It is
// possible to call close() on a consumer that has
--- 635,645 ----
synchronized (stopLock) {
// Notify listeners while holding stopLock to guarantee
// that listeners finish executing consumerStopped()
// before the stop() method returns.
synchronized (this) {
! if (state == State.STOPPED || state == State.CLOSED) {
//
// This consumer was stopped just after calling
// go() but before starting (the premature return
// case at the top of this work() method). It is
// possible to call close() on a consumer that has