mresultwriter.java

httptunnel.jar httptunnel java 源码

package net.jumperz.app.MRemedy;

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

public class MResultWriter
extends MSingleThreadCommand
{
private static final MResultWriter instance = new MResultWriter();

private int lastIndex = -1;
private Map indexResultMap = new HashMap();
//--------------------------------------------------------------------------------
public static MResultWriter getInstance()
{
return instance;
}
//--------------------------------------------------------------------------------
private MResultWriter()
{
mutex = new Object();
}
//--------------------------------------------------------------------------------
public void execute2()
{
while( true )
	{
	Integer nextIndex = new Integer( lastIndex + 1 );
	if( indexResultMap.containsKey( nextIndex ) )
		{
		try
			{
			System.out.write( ( ( String )indexResultMap.get( nextIndex ) ).getBytes( MCharset.CS_ISO_8859_1 ) );		
			System.out.write( 0x0A );
			}
		catch( IOException e )
			{
			e.printStackTrace();
			}

		lastIndex++;

		synchronized( indexResultMap )
			{
			indexResultMap.remove( nextIndex );
			}
		}
	else
		{
		break;
		}
	}
}
//--------------------------------------------------------------------------------
public void putResult( Integer index, String result )
{
synchronized( indexResultMap )
	{
	indexResultMap.put( index, result );
	}

synchronized( mutex )
	{
	mutex.notify();
	}
}
//--------------------------------------------------------------------------------
public void breakCommand()
{
}
//--------------------------------------------------------------------------------
}