Changeset 30 for chess

Timestamp:

02/08/09 17:55:18 (13 years ago)

Author:

BegemoT

Message:

threading issues

File:

• chess/src/chess/remote/impl/BTNode.java (modified) (4 diffs)

chess/src/chess/remote/impl/BTNode.java

@@ -38 +38 @@
 
         /** ìîíèòîð îæèäàíèÿ îòêðûòèÿ ñîåäèíåíèÿ */
-        private final Object connectLock = new Object();
+//      private final Object connectLock = new Object();
 
         private final Object queueOverloadedLock = new Object();
@@ -103 +103 @@
         public void send( final IDatagram data ) {
                 checkPumpActive();
-                synchronized( connectLock ) {
-                        while( !isConnected() && !isClosed() ) {
-                                try {
-                                        connectLock.wait( 250 );
-                                } catch( InterruptedException e ) {
-                                        e.printStackTrace();
-                                }
-                        }
-                }
+//              synchronized( connectLock ) {
+//                      while( !isConnected() && !isClosed() ) {
+//                              try {
+//                                      connectLock.wait( 250 );
+//                              } catch( InterruptedException e ) {
+//                                      e.printStackTrace();
+//                              }
+//                      }
+//              }
                 //áëîêèðóåì this ÷òîáû íàñ íå çàêðûëè íåâîâðåìÿ
                 while( true ) {
@@ -152 +152 @@
                                 listener.connected();
                         }
-                        synchronized( connectLock ) {
-                                connectLock.notifyAll();
-                        }
+//                      synchronized( connectLock ) {
+//                              connectLock.notifyAll();
+//                      }
                         final GenericDatagram data = new GenericDatagram();
                         while( !isClosed() ) {
@@ -201 +201 @@
         }
 
-        public synchronized void close() {
+        public void close() {
                 if( isClosed() ) {
                         return;