Mercurial > hg > Members > shoshi > TreeCMSv2

comparison src/treecms/tree/cassandra/v1/ClientThreadFactory.java @ 7:fc19e38b669b

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
added concurrent access client for cassandr
author shoshi
date Thu, 17 Mar 2011 23:24:08 +0900
parents
children
comparison
equal deleted inserted replaced
6:12604eb6b615 7:fc19e38b669b
1 package treecms.tree.cassandra.v1;
2
3 import java.util.concurrent.ThreadFactory;
4
5 import org.apache.thrift.transport.TTransportException;
6
7 /**
8 * ローカル変数としてCassandra.Clientを保持するスレッドオブジェクトを生成するスレッドファクトリーです。
9 * @author shoshi
10 */
11 final class ClientThreadFactory implements ThreadFactory
12 {
13 private String m_host;
14 private int m_port;
15
16 /**
17 * コンストラクタです。
18 * @param _host Cassandraのアドレス・ホスト名
19 * @param _port Thriftポート番号
20 */
21 public ClientThreadFactory(String _host,int _port)
22 {
23 m_host = _host;
24 m_port = _port;
25 }
26
27 /**
28 * Cassandra.Clientを保持するスレッドオブジェクトを新しく作成します。
29 */
30 @Override
31 public Thread newThread(Runnable _runnable)
32 {
33 ClientThread client = null;
34 try{
35 client = ClientThread.newInstance(m_host,m_port,_runnable);
36 }catch(TTransportException _e) {
37 _e.printStackTrace();
38 throw new RuntimeException(_e);
39 }
40 return client;
41 }
42 }