worker thread

gistfile1.txt

class InsertThread extends Thread{
	TitanGraph g=TitanFactory.open("/Users/lili/soft/titan-server-0.4.4/conf/titan-hbase-es.properties");
	BlockingQueue<String> queue;
	public InsertThread(BlockingQueue<String> queue){
		this.queue=queue;
	}
	@Override
	public void run(){
		while(true){
			try {
				String s=queue.take();
				try{
					Vertex v=g.addVertex(null);
					v.setProperty("uri", s);
					g.commit();
				}catch(Exception e){
					
				}
			} catch (InterruptedException e) {
				
			}
			
		}
	}
}