Package com.dp.nebula.wormhole.common.interfaces

Examples of com.dp.nebula.wormhole.common.interfaces.ILine.addField()


  public void queueTest(){
    SingleQueue dq = new SingleQueue(200,1024*200);
    ILine setLine,getLine = null;
    setLine = new DefaultLine();
    setLine.addField("1");
    setLine.addField("sunny");
    try {
      dq.push(setLine, 1, TimeUnit.MILLISECONDS);
      getLine = dq.pull(1, TimeUnit.MILLISECONDS);
    } catch (InterruptedException e) {
      e.printStackTrace();
View Full Code Here


    SingleQueue dq = new SingleQueue(200,1024*200);
    ILine[] setLines,getLines = null;
    setLines = new ILine[10];
    getLines = new ILine[10];
    ILine item1 = new DefaultLine();
    item1.addField("1");
    item1.addField("sunny");
    ILine item2 = new DefaultLine();
    item2.addField("2");
    item2.addField("jack");
    setLines[0]=item1;
View Full Code Here

    ILine[] setLines,getLines = null;
    setLines = new ILine[10];
    getLines = new ILine[10];
    ILine item1 = new DefaultLine();
    item1.addField("1");
    item1.addField("sunny");
    ILine item2 = new DefaultLine();
    item2.addField("2");
    item2.addField("jack");
    setLines[0]=item1;
    setLines[1]=item2;
View Full Code Here

    getLines = new ILine[10];
    ILine item1 = new DefaultLine();
    item1.addField("1");
    item1.addField("sunny");
    ILine item2 = new DefaultLine();
    item2.addField("2");
    item2.addField("jack");
    setLines[0]=item1;
    setLines[1]=item2;
    try {
      dq.push(setLines,2, 1, TimeUnit.MILLISECONDS);
View Full Code Here

    ILine item1 = new DefaultLine();
    item1.addField("1");
    item1.addField("sunny");
    ILine item2 = new DefaultLine();
    item2.addField("2");
    item2.addField("jack");
    setLines[0]=item1;
    setLines[1]=item2;
    try {
      dq.push(setLines,2, 1, TimeUnit.MILLISECONDS);
      dq.pull(getLines, 1, TimeUnit.MILLISECONDS);
View Full Code Here

  @Test
  public void queueTest(){
    DoubleQueue dq = new DoubleQueue(200,1024*200);
    ILine setLine,getLine = null;
    setLine = new DefaultLine();
    setLine.addField("1");
    setLine.addField("sunny");
    try {
      dq.push(setLine, 1, TimeUnit.MILLISECONDS);
      getLine = dq.pull(1, TimeUnit.MILLISECONDS);
    } catch (InterruptedException e) {
View Full Code Here

  public void queueTest(){
    DoubleQueue dq = new DoubleQueue(200,1024*200);
    ILine setLine,getLine = null;
    setLine = new DefaultLine();
    setLine.addField("1");
    setLine.addField("sunny");
    try {
      dq.push(setLine, 1, TimeUnit.MILLISECONDS);
      getLine = dq.pull(1, TimeUnit.MILLISECONDS);
    } catch (InterruptedException e) {
      e.printStackTrace();
View Full Code Here

    DoubleQueue dq = new DoubleQueue(200,1024*200);
    ILine[] setLines,getLines = null;
    setLines = new ILine[10];
    getLines = new ILine[10];
    ILine item1 = new DefaultLine();
    item1.addField("1");
    item1.addField("sunny");
    ILine item2 = new DefaultLine();
    item2.addField("2");
    item2.addField("jack");
    setLines[0]=item1;
View Full Code Here

    ILine[] setLines,getLines = null;
    setLines = new ILine[10];
    getLines = new ILine[10];
    ILine item1 = new DefaultLine();
    item1.addField("1");
    item1.addField("sunny");
    ILine item2 = new DefaultLine();
    item2.addField("2");
    item2.addField("jack");
    setLines[0]=item1;
    setLines[1]=item2;
View Full Code Here

    getLines = new ILine[10];
    ILine item1 = new DefaultLine();
    item1.addField("1");
    item1.addField("sunny");
    ILine item2 = new DefaultLine();
    item2.addField("2");
    item2.addField("jack");
    setLines[0]=item1;
    setLines[1]=item2;
    try {
      dq.push(setLines,2, 1, TimeUnit.MILLISECONDS);
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.