|
0
|
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 }
|
