?? groupconcurrencyproblemtestcase.java
字號:
/*
* Copyright (c) 2002-2003 by OpenSymphony
* All rights reserved.
*/
package com.opensymphony.oscache.base;
import com.opensymphony.oscache.general.GeneralCacheAdministrator;
import junit.framework.TestCase;
/**
* DOCUMENT ME!
*
* @author $author$
* @version $Revision: 254 $
*/
public class GroupConcurrencyProblemTestCase extends TestCase {
private static GeneralCacheAdministrator cache = new GeneralCacheAdministrator();
public static void main(String[] args) {
System.out.println("START");
// Create some clients and start them running.
for (int i = 0; i < 100; i++) {
System.out.println("Creating thread: " + i);
new Client(i, cache).start();
}
System.out.println("END");
}
}
/* Inner class to hammer away at the cache. */
class Client extends Thread {
private static final int MAX_ITERATIONS = 1000;
private GeneralCacheAdministrator cache;
private int id;
public Client(int newId, GeneralCacheAdministrator newCache) {
super();
id = newId;
cache = newCache;
}
public void run() {
for (int i = 0; i < MAX_ITERATIONS; i++) {
/* Put an entry from this Client into the shared group.
*/
cache.putInCache(Integer.toString(id), "Some interesting data", new String[] {
"GLOBAL_GROUP"
});
// Flush that group.
cache.flushGroup("GLOBAL_GROUP");
}
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -