Mercurial > hg > Members > shoshi > TreeCMSv2
view src/treecms/cassandra/util/CassandraClientThreadFactory.java @ 17:168deb591f21
commit
author | shoshi |
---|---|
date | Tue, 24 May 2011 00:33:12 +0900 |
parents | src/treecms/tree/cassandra/v1/util/CassandraClientThreadFactory.java@17ed97ca9960 |
children |
line wrap: on
line source
package treecms.cassandra.util; import java.util.concurrent.ThreadFactory; import org.apache.thrift.transport.TTransportException; /** * ローカル変数としてCassandra.Clientを保持するスレッドオブジェクトを生成するスレッドファクトリーです。 * @author shoshi */ final class CassandraClientThreadFactory implements ThreadFactory { private String m_host; private int m_port; /** * コンストラクタです。 * @param _host Cassandraのアドレス・ホスト名 * @param _port Thriftポート番号 */ public CassandraClientThreadFactory(String _host,int _port) { m_host = _host; m_port = _port; } /** * Cassandra.Clientを保持するスレッドオブジェクトを新しく作成します。 */ @Override public Thread newThread(Runnable _runnable) { CassandraClientThread client = null; try{ client = CassandraClientThread.newInstance(m_host,m_port,_runnable); }catch(TTransportException _e) { _e.printStackTrace(); throw new RuntimeException(_e); } return client; } }