1 package org.wamblee.socketproxy;
4 * Copyright (c) 2005 UPS_SCS NL
10 private int _countLeft;
12 public Barrier( int aCount ) {
16 public synchronized void block( ) {
18 if ( _countLeft < 0 ) {
19 throw new IllegalStateException(
20 "Barrier count became negative, programming error" );
23 while ( _countLeft > 0 ) {
24 waitUninterruptable( );
28 private void waitUninterruptable( ) {
31 } catch ( InterruptedException e ) {