lookupthread.java

来自「char44-2 处理web服务器的记录文件 提供了本书第4章的处理we」· Java 代码 · 共 45 行

//LookupThread.java
import java.net.*;
import java.io.*;
import java.util.*;
public class LookupThread extends Thread {
	private List entries;
	PooledWeblog log; //在回调的时候使用
	public LookupThread(List entries, PooledWeblog log) {
		this.entries = entries;
		this.log = log;
	}
	public void run( ) {
		String entry;
		while (true) {
			synchronized (entries) {
				while (entries.size( ) == 0) {
					if (log.isFinished( )) return;
					try {
						entries.wait( );
					}
					catch (InterruptedException e) {
					}
				}
				entry = (String) entries.remove(entries.size( )-1);
			}
			int index = entry.indexOf(' ', 0);
			//获得远程主机地址
			String remoteHost = entry.substring(0, index);
			String theRest = entry.substring(index, entry.length( ));
			try {
				remoteHost =
					InetAddress.getByName(remoteHost).getHostName( );
			}
			catch (Exception e) {
			}
			try {
				log.log(remoteHost + theRest);
			}
			catch (IOException e) {
			}
			this.yield( );
		}
	}
}