?? writetest.java
字號:
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 WriteTest {
/**
* Logger for this class
*/
private static final Logger logger = Logger.getLogger(WriteTest.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 == 1)
pool.execute(new Writer(i * 281));
}
while (pool.getActiveCount() > 0)
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
pool.shutdown();
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -