package com.bci.commons.mmf.example;

import java.util.Random;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

import org.apache.log4j.Logger;

public class WriteTest2 {
	/**
	 * Logger for this class
	 */
	private static final Logger logger = Logger.getLogger(WriteTest2.class);

	private static final int MAX_COUNT = 1000;

	private static CMPP3SubmitMMF map = new CMPP3SubmitMMF();

	private static ThreadPoolExecutor pool = new ThreadPoolExecutor(100, 100,
			50000L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>());

	private static Random rand = new Random();

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

		class Writer implements Runnable {

			private int pos = 0;

			public Writer(int _pos) {
				this.pos = _pos;
			}

			public void run() {
				logger.info(Thread.currentThread().getId()
						+ "__writing data:pos=" + pos);
				long old = map.readLong(pos + 113);
				logger.info(Thread.currentThread().getId() + "__old value="
						+ old);
				long ll = rand.nextLong();
				map.write(pos + 113, ll, 8);
				logger.info(Thread.currentThread().getId() + "__new value="
						+ ll);
				ll = map.readLong(pos + 113);
				if (ll == old) {
					logger.error(Thread.currentThread().getId()
							+ "__update failure!");
				}
			}

		}
		org.apache.log4j.PropertyConfigurator
				.configure("config/mtci_log4j.properties");
		map.load("data/deliver_test", MAX_COUNT);
		for (int x = 0; x < 100; x++)
			for (int i = 0; i < MAX_COUNT; i++) {
				if (i % 2 == 0)
					pool.execute(new Writer(i * 281));
			}

		while (pool.getActiveCount() > 0)
			try {
				Thread.sleep(1000);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		pool.shutdown();
	}
}