公司产品要集成LDAP,可以支持5个LDAP服务器,我们要写代码定期和LDAP服务器的信息进行同步,但是每个LDAP服务器的同步周期是变化的,用户可以配置。最简单的方式就是每个LDAP起一个线程做这个工作,但是架构师不允许太多的线程,所以要用一个主线程来控制。本来负责这个功能的人要使用轮询的方式,因为他觉得用户什么时候修改那个周期是不确定的,所以要一直查。其实很简单,如果其它的地方修改了那个周期,它通知那个主线程哪个服务器的周期修改了就行,然后主线程中断休眠并重新计算应该休眠的时间。主线程大部分时间都处于休眠状态,每次都会重新计算下一次应该休眠多长时间,这样程序的性能就大大的提高了。
演示代码如下:
import java.util.ArrayList;
import java.util.List;
public class MainThread extends Thread {
private List servers;
private static MainThread instance;
public static void updatePeriod(String serverName, long period) {
for (int i = 0; i < instance.servers.size(); i++) {
Object[] server = (Object[]) instance.servers.get(i);
if (server[0].equals(serverName)) {
server[2] = new Long(period);
break;
}
}
instance.interrupt();
}
public MainThread() {
instance = this;
servers = new ArrayList();
Object[] server1 = new Object[3];
server1[0] = "server1";
server1[1] = new Long(System.currentTimeMillis());
server1[2] = new Long(2000);
servers.add(server1);
Object[] server2 = new Object[3];
server2[0] = "server2";
server2[1] = new Long(System.currentTimeMillis());
server2[2] = new Long(3000);
servers.add(server2);
}
public void run() {
while (true) {
try {
long current = System.currentTimeMillis();
long sleepTime = Long.MAX_VALUE;
for (int i = 0; i < servers.size(); i++) {
Object[] server = (Object[]) servers.get(i);
long last = ((Long) server[1]).longValue();
long period = ((Long) server[2]).longValue();
long next = last + period;
long sleep = next – current;
if (sleepTime > sleep) {
sleepTime = sleep;
}
if (sleep <= 0) {
System.out.println("Synch thread started.");
server[1] = new Long(current);
}
}
if (sleepTime > 0) {
Thread.sleep(sleepTime);
}
} catch (InterruptedException e) {
System.out.println("Interrupted.");
} catch (Throwable t) {
}
}
}
public static void main(String[] args) {
MainThread thread = new MainThread();
thread.start();
try {
for (int i = 0; i < 10; i++) {
Thread.sleep(2000);
updatePeriod("server1", 3000);
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
要强调一点的是,几乎所有的轮询都可以使用类似都方式解决,轮询做太多的无用功。另外一种好的方式就是使用Observer模式,和这个的性能类似。
发表评论