package com.lucky.concurrent.list;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class CopyOnWriteArrayListDemo {
	/**
	 * 讀線程
	 * @author wangjie
	 *
	 */
	private static class ReadTask implements Runnable {
		List<String> list;
		public ReadTask(List<String> list) {
			this.list = list;
		}
		public void run() {
			for (String str : list) {
				System.out.println(str);
			}
		}
	}
	/**
	 * 寫線程
	 * @author wangjie
	 *
	 */
	private static class WriteTask implements Runnable {
		List<String> list;
		int index;
		public WriteTask(List<String> list, int index) {
			this.list = list;
			this.index = index;
		}
		public void run() {
			list.remove(index);
			list.add(index, "write_" + index);
		}
	}
	public void run() {
		final int NUM = 10;
		List<String> list = new ArrayList<String>();
		for (int i = 0; i < NUM; i++) {
			list.add("main_" + i);
		}
		ExecutorService executorService = Executors.newFixedThreadPool(NUM);
		for (int i = 0; i < NUM; i++) {
			executorService.execute(new ReadTask(list));
			executorService.execute(new WriteTask(list, i));
		}
		executorService.shutdown();
	}
	public static void main(String[] args) {
		new CopyOnWriteArrayListDemo().run();
	}
}

/**
     * Appends the specified element to the end of this list.
     *
     * @param e element to be appended to this list
     * @return <tt>true</tt> (as specified by {@link Collection#add})
     */
    public boolean add(E e) {
	final ReentrantLock lock = this.lock;
	lock.lock();
	try {
	    Object[] elements = getArray();
	    int len = elements.length;
	    Object[] newElements = Arrays.copyOf(elements, len + 1);
	    newElements[len] = e;
	    setArray(newElements);
	    return true;
	} finally {
	    lock.unlock();
	}
    }

//		List<String> list = new ArrayList<String>();
		CopyOnWriteArrayList<String> list = new CopyOnWriteArrayList<String>();