Mercurial > hg > Members > kazuma > jungle-ormapper
comparison src/main/java/jp/ac/u_ryukyu/ie/cr/jungle/test/JungleWriteThread.java @ 0:44465893e8b8
first Commit
| author | Kazuma |
|---|---|
| date | Wed, 30 Nov 2016 01:47:55 +0900 |
| parents | |
| children |
comparison
equal
deleted
inserted
replaced
| -1:000000000000 | 0:44465893e8b8 |
|---|---|
| 1 package jp.ac.u_ryukyu.ie.cr.jungle.test; | |
| 2 | |
| 3 import jp.ac.u_ryukyu.ie.cr.jungle.JungleTree; | |
| 4 import jp.ac.u_ryukyu.ie.cr.jungle.JungleTreeEditor; | |
| 5 import jp.ac.u_ryukyu.ie.cr.jungle.store.impl.DefaultNodePath; | |
| 6 | |
| 7 import java.nio.ByteBuffer; | |
| 8 | |
| 9 | |
| 10 public class JungleWriteThread extends Thread { | |
| 11 | |
| 12 JungleTree tree; | |
| 13 boolean loop = true; | |
| 14 private int writeCount; | |
| 15 | |
| 16 public JungleWriteThread(JungleTree tree) { | |
| 17 this.tree = tree; | |
| 18 } | |
| 19 | |
| 20 public void set(boolean flag) { | |
| 21 loop = flag; | |
| 22 } | |
| 23 | |
| 24 public void get() { | |
| 25 System.out.println("writeCount = " + writeCount); | |
| 26 } | |
| 27 | |
| 28 @Override | |
| 29 public void run() { | |
| 30 while (loop) { | |
| 31 try { | |
| 32 Thread.sleep(100); | |
| 33 } catch (InterruptedException e) { | |
| 34 e.printStackTrace(); | |
| 35 } | |
| 36 JungleTreeEditor editor = tree.getTreeEditor(); | |
| 37 editor = editor.putAttribute(new DefaultNodePath(), "key", ByteBuffer.wrap(String.valueOf(0).getBytes())).b(); | |
| 38 if (editor.success().isA()) | |
| 39 System.out.println("faild"); | |
| 40 else | |
| 41 writeCount++; | |
| 42 } | |
| 43 } | |
| 44 } |