import java.nio.ByteBuffer;
import java.util.Random;

public class test {

    ByteBuffer buffer = ByteBuffer.allocate(1024);

    Object lock = new Object();

    /**
     * @param args
     */
    public static void main(String[] args) {

        test x = new test();
        x.go();

    }

    private void go() {
        new PutDataThread().start();
        new GetDataThread().start();

    }

    //放数据的线程
    class PutDataThread extends Thread {
        public void run() {
            buffer.rewind(); //指针挪到0
            
            int i = 0;
            while (i < 255) {
                synchronized (lock) {
                    System.out.println("put " + i);
                    buffer.put((byte) i);
                }

                //sleep一会
                try {
                    Thread.sleep(new Random().nextInt(1000));
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

                i++;
                if (i == 254) {
                    i = 0;
                }
            }
        }
    }

    //取数据线程
    class GetDataThread extends Thread {
        public void run() {
            while (true) {
                
                //读数据要同步
                synchronized (lock) {
                    byte[] aa = new byte[buffer.position()];
                    buffer.position(0); //指针挪到0
                    buffer.get(aa); //数据读入数组
                    buffer.position(0); //指针挪回0
                    
                    //打印（实际应把其他工作挪到同步外面进行，这里为了打印顺序不乱，放在了里面）
                    System.out.print("-----get--");
                    for (int i = 0; i < aa.length; i++) {
                        System.out.print(aa[i] + " ");
                    }
                    System.out.println("-------");
                }
                
                //sleep一会
                try {
                    Thread.sleep(new Random().nextInt(2000));
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }

}