mdeaddrop.java

来自「httptunnel.jar httptunnel java 源码」· Java 代码 · 共 45 行

package net.jumperz.app.MDeadDrop;

import java.io.*;
import net.jumperz.util.*;
import net.jumperz.net.*;

public class MDeadDrop
{
private static final int THREAD_COUNT = 100;
private MThreadPool threadPool;
//----------------------------------------------------------------------------------------
public static void main( String[] args )
throws Exception
{
if( args.length != 1 )
	{
	System.err.println( "Usage: java net.jumperz.app.MDeadDrop.MDeadDrop URL_LIST_FILE_NAME" );
	return;
	}
else
	{
	new MDeadDrop().start( args[ 0 ] );
	}
}
//----------------------------------------------------------------------------------------
private void start( String urlListFileName )
throws IOException
{
threadPool = new MThreadPool( MDeadDrop.THREAD_COUNT );

BufferedReader reader = new BufferedReader( new InputStreamReader( new FileInputStream( urlListFileName ), MCharset.CS_ISO_8859_1 ) );
String line;
while( true )
	{
	line = reader.readLine();
	if( line == null )
		{
		break;
		}
	MDropAgent agent = new MDropAgent( line );
	threadPool.addCommand( agent );
	}
}
//----------------------------------------------------------------------------------------
}