org.jredis.bench

Class JRedisBenchmark.BenchmarkWorker

java.lang.Object

org.jredis.bench.JRedisBenchmark.BenchmarkWorker

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

JRedisBenchmark

public abstract class JRedisBenchmark.BenchmarkWorker
extends java.lang.Object
implements java.lang.Runnable

Abstract base class for all benchmark workers. This is a runnable that uses the template pattern in the run method and takes care of common time keeping tasks for the specific (child class) workers.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) java.util.concurrent.CountDownLatch	completion
(package private) int	db
(package private) long[]	deltas
(package private) java.lang.String	host
(package private) int	id
(package private) JRedis	jredis
(package private) java.util.concurrent.CountDownLatch	mark
(package private) int	port
(package private) java.util.concurrent.CountDownLatch	ready
(package private) int	reqCnt

Constructor Summary

Constructors

Constructor and Description
BenchmarkWorker(java.lang.String host, int port, int db)

Method Summary

Modifier and Type	Method and Description
protected abstract void	prep() anything that needs to be done to setup the calls -- typically all time consuming data setup tasks go here ...
void	run() 1 - connects to the redis server
protected abstract void	work() Typically just a tight loop calling the redis server for the given test and using the data prep'd in prep()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

host

final java.lang.String host

port

final int port

deltas

long[] deltas

ready

java.util.concurrent.CountDownLatch ready

completion

java.util.concurrent.CountDownLatch completion

mark

java.util.concurrent.CountDownLatch mark

reqCnt

int reqCnt

id

int id

db

int db

jredis

JRedis jredis

Constructor Detail

BenchmarkWorker

public BenchmarkWorker(java.lang.String host,
                       int port,
                       int db)

Method Detail

run

public void run()

1 - connects to the redis server

2 - calls the prep() -- subclasses will implement this

3 - waits for the mark signal to start the calls

4 - gets the sys time, and ..

5 - calls the work() method -- subclasses will implement this

6 - gets the sys time -- this is the time delta for this worker

7 - closes the connection, and signals completion to the benchmarker.

Specified by:

run in interface java.lang.Runnable

prep

protected abstract void prep()

anything that needs to be done to setup the calls -- typically all time consuming data setup tasks go here ...

work

protected abstract void work()

Typically just a tight loop calling the redis server for the given test and using the data prep'd in prep()