クラス org.objectweb.cjdbc.driver.ConnectionClosingThread

org.objectweb.cjdbc.driver.ConnectionClosingThreadのコラボレーション図

[凡例]すべてのメンバ一覧

---

説明

The ConnectionClosingThread wakes up every 5 seconds when close() has been called on a connection and it frees the connection if it has not been reused.

作者:

Emmanuel Cecchet

バージョン:

1.0

ConnectionClosingThread.java の 39 行で定義されています。

Public メソッド
	ConnectionClosingThread (Driver driver)
void	run ()
Private メソッド
void	closeConnection (Connection c)
Private 変数
Driver	driver
ArrayList	pendingConnectionClosing
Static Private 変数
final int	WAIT_TIME = 5000

---

コンストラクタとデストラクタ

org.objectweb.cjdbc.driver.ConnectionClosingThread.ConnectionClosingThread (  Driver  driver  )

Builds a new ConnectionClosingThread 引数: driver  The driver that created us ConnectionClosingThread.java の 52 行で定義されています。 参照先 org.objectweb.cjdbc.driver.Driver.connectionClosingThreadisAlive, と org.objectweb.cjdbc.driver.Driver.pendingConnectionClosing. { super("ConnectionClosingThread"); this.driver = driver; this.pendingConnectionClosing = driver.pendingConnectionClosing; driver.connectionClosingThreadisAlive = true; }

---

メソッド

void org.objectweb.cjdbc.driver.ConnectionClosingThread.closeConnection (  Connection  c  )  [private]

Closes a connection. 引数: c  the connection to close ConnectionClosingThread.java の 142 行で定義されています。 参照先 org.objectweb.cjdbc.driver.Connection.driver, org.objectweb.cjdbc.driver.Connection.socket, org.objectweb.cjdbc.driver.Connection.socketInput, と org.objectweb.cjdbc.driver.Connection.socketOutput. 参照元 org.objectweb.cjdbc.driver.ConnectionClosingThread.run(). { try { // Unlink those objects so that this connection can be garbage collected c.driver = null; if (c.socketOutput != null) { c.socketOutput.writeInt(Commands.Close); c.socketOutput.flush(); if (c.socketInput != null) { // Wait for the controller to receive the connection and close the // stream. If we do not wait for the controller ack, the connection is // closed on the controller before the closing is handled which // results in an ugly warning message on the controller side. We are // not in a hurry when closing the connection so let do the things // nicely! c.socketInput.readObject(); c.socketInput.close(); } c.socketOutput.close(); } if (c.socket != null) c.socket.close(); } catch (Exception ignore) { } }

void org.objectweb.cjdbc.driver.ConnectionClosingThread.run (   )

The connection closing thread wakes up every WAIT_TIME seconds when close() has been called on a connection and it frees the connection if it has not been reused. ConnectionClosingThread.java の 65 行で定義されています。 参照先 org.objectweb.cjdbc.driver.ConnectionClosingThread.closeConnection(), org.objectweb.cjdbc.driver.Driver.connectionClosingThreadisAlive, org.objectweb.cjdbc.driver.ConnectionClosingThread.driver, org.objectweb.cjdbc.driver.ConnectionClosingThread.pendingConnectionClosing, と org.objectweb.cjdbc.driver.ConnectionClosingThread.WAIT_TIME. { try { Connection firstConnectionToClose = null; Connection lastConnectionToClose = null; int pendingConnectionSize; ArrayList closingList = new ArrayList(); boolean killed = false; while (!killed) { synchronized (pendingConnectionClosing) { pendingConnectionSize = pendingConnectionClosing.size(); if (pendingConnectionSize == 0) break; try { // Look at the connections in the queue before sleeping firstConnectionToClose = (Connection) pendingConnectionClosing .get(0); lastConnectionToClose = (Connection) pendingConnectionClosing .get(pendingConnectionSize - 1); // Sleep pendingConnectionClosing.wait(WAIT_TIME); } catch (InterruptedException ignore) { } pendingConnectionSize = pendingConnectionClosing.size(); // Exit, no more connections if (pendingConnectionSize == 0) break; // Compare the queue now with its state when we got to sleep if (firstConnectionToClose == pendingConnectionClosing.get(0)) { // Ok, the connection has not been reused, let's close it if (lastConnectionToClose == (Connection) pendingConnectionClosing .get(pendingConnectionSize - 1)) { // No connection has been reused, remove them all closingList.addAll(pendingConnectionClosing); pendingConnectionClosing.clear(); killed = true; // Let's die, there are no more connections } else // Close only the first connection closingList.add(pendingConnectionClosing.remove(0)); } } // Effectively close the connections outside the synchronized block while (!closingList.isEmpty()) closeConnection((Connection) closingList.remove(0)); } } catch (RuntimeException e) { e.printStackTrace(); } finally { synchronized (pendingConnectionClosing) { driver.connectionClosingThreadisAlive = false; } } }

---

変数

Driver org.objectweb.cjdbc.driver.ConnectionClosingThread.driver [private]

ConnectionClosingThread.java の 44 行で定義されています。 参照元 org.objectweb.cjdbc.driver.ConnectionClosingThread.run().

ArrayList org.objectweb.cjdbc.driver.ConnectionClosingThread.pendingConnectionClosing [private]

ConnectionClosingThread.java の 45 行で定義されています。 参照元 org.objectweb.cjdbc.driver.ConnectionClosingThread.run().

final int org.objectweb.cjdbc.driver.ConnectionClosingThread.WAIT_TIME = 5000 [static, private]

ConnectionClosingThread.java の 42 行で定義されています。 参照元 org.objectweb.cjdbc.driver.ConnectionClosingThread.run().

---

このクラスの説明は次のファイルから生成されました:

• src/org/objectweb/cjdbc/driver/ConnectionClosingThread.java

---