gearman 处理类

import java.util.ArrayList;import java.util.List;import org.gearman.client.GearmanJobResult;import org.gearman.client.GearmanJobResultImpl;import org.gearman.util.ByteUtils;import org.gearman.worker.AbstractGearmanFunction;//真正的业务逻辑public class ReverseFunction extends AbstractGearmanFunction {        public GearmanJobResult executeFunction() {    GearmanJobResult gjr=null;      //  StringBuffer sb = new StringBuffer(ByteUtils.fromUTF8Bytes((byte[]) this.data));        for(int i=0;i<10;i++){         StringBuffer sb = new StringBuffer(ByteUtils.fromUTF8Bytes((byte[]) this.data));                 gjr = new GearmanJobResultImpl(this.jobHandle,                true, sb.reverse().toString().getBytes(),                new byte[0], new byte[0], 0, 0);         System.out.println("--"+sb.toString()+"--");         try {Thread.sleep(1000);} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}        }        return gjr;    }}class show extends Thread{  public void run(){  ClientTest test=new ClientTest("192.168.101.143", 4730);             System.out.println(test.reverse("hello"));  } }