alphazero · August 13, 2010 02:51 · alphazero · Aug 13, 2010 · alphazero · Aug 13, 2010
diff --git a/Continuous SET Op - O(1)? b/Continuous SET Op - O(1)?
 /*
 *   Copyright 2010 Joubin Houshyar
 * 
 *   Licensed under the Apache License, Version 2.0 (the "License");
 *   you may not use this file except in compliance with the License.
 *   You may obtain a copy of the License at
 *    
 *   http://www.apache.org/licenses/LICENSE-2.0
 *    
 *   Unless required by applicable law or agreed to in writing, software
 *   distributed under the License is distributed on an "AS IS" BASIS,
 *   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *   See the License for the specific language governing permissions and
 *   limitations under the License.
 */

 package org.jredis.ri.alphazero.bench;

 import java.io.Serializable;
 import org.jredis.JRedis;
 import org.jredis.RedisException;
 import org.jredis.bench.Util.Timer;
 import org.jredis.connector.ConnectionSpec;
 import org.jredis.ri.alphazero.JRedisClient;
 import org.jredis.ri.alphazero.connection.DefaultConnectionSpec;

 /**
 * [TODO: document me!]
 *
 * @author  joubin ([email protected])
 * @date    Aug 12, 2010
 * 
 */

 public class JRedisClientContinuousOpBenchmark {

 	public static void main (String[] args) {
 	    new JRedisClientContinuousOpBenchmark().run();
    }
 	public void run() {
 		int reps = 1000;

 		ConnectionSpec spec = DefaultConnectionSpec.newSpec()
 			.setCredentials("jredis".getBytes())
 			.setDatabase(13);	// << we will flush this db
 		
 		JRedis jredis = new JRedisClient(spec);
 		
 		try {
 	        jredis.flushdb();
 			for(;;) benchOp(jredis, reps);
        }
        catch (RedisException e) {
 	        e.printStackTrace();
        }
 	}
 	private void benchOp(JRedis jredis, int reps){
 		Timer timer = Timer.startNewTimer();
 		String key = "baby!";
 		try {
 			for(int i=0; i<reps; i++) {
 				Woof woof = new Woof();
 				jredis.set(key+woof.timestamp, woof);
 			}
        }
        catch (RedisException e) {
 	        e.printStackTrace();
        }
        finally {
        	timer.mark();
        	System.out.format("delta: %d - keys: %09d \n", timer.deltaAtMark(), keyCnt(jredis));
        }

 	}
 	private long keyCnt (JRedis jRedis) {
 		try {
 	        return jRedis.dbsize();
        }
        catch (RedisException e) {
 	        throw new RuntimeException("", e);
        }
 	}
 	@SuppressWarnings("serial")
    public static class Woof implements Serializable {
 		public final long timestamp = System.currentTimeMillis();
 	}
 }
	/*
	* Copyright 2010 Joubin Houshyar
	*
	* Licensed under the Apache License, Version 2.0 (the "License");
	* you may not use this file except in compliance with the License.
	* You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software
	* distributed under the License is distributed on an "AS IS" BASIS,
	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	* See the License for the specific language governing permissions and
	* limitations under the License.
	*/

	package org.jredis.ri.alphazero.bench;

	import java.io.Serializable;
	import org.jredis.JRedis;
	import org.jredis.RedisException;
	import org.jredis.bench.Util.Timer;
	import org.jredis.connector.ConnectionSpec;
	import org.jredis.ri.alphazero.JRedisClient;
	import org.jredis.ri.alphazero.connection.DefaultConnectionSpec;

	/**
	* [TODO: document me!]
	*
	* @author joubin ([email protected])
	* @date Aug 12, 2010
	*
	*/

	public class JRedisClientContinuousOpBenchmark {

	public static void main (String[] args) {
	new JRedisClientContinuousOpBenchmark().run();
	}
	public void run() {
	int reps = 1000;

	ConnectionSpec spec = DefaultConnectionSpec.newSpec()
	.setCredentials("jredis".getBytes())
	.setDatabase(13); // << we will flush this db

	JRedis jredis = new JRedisClient(spec);

	try {
	jredis.flushdb();
	for(;;) benchOp(jredis, reps);
	}
	catch (RedisException e) {
	e.printStackTrace();
	}
	}
	private void benchOp(JRedis jredis, int reps){
	Timer timer = Timer.startNewTimer();
	String key = "baby!";
	try {
	for(int i=0; i<reps; i++) {
	Woof woof = new Woof();
	jredis.set(key+woof.timestamp, woof);
	}
	}
	catch (RedisException e) {
	e.printStackTrace();
	}
	finally {
	timer.mark();
	System.out.format("delta: %d - keys: %09d \n", timer.deltaAtMark(), keyCnt(jredis));
	}

	}
	private long keyCnt (JRedis jRedis) {
	try {
	return jRedis.dbsize();
	}
	catch (RedisException e) {
	throw new RuntimeException("", e);
	}
	}
	@SuppressWarnings("serial")
	public static class Woof implements Serializable {
	public final long timestamp = System.currentTimeMillis();
	}
	}