sendfilethreadfactory.java

来自「JAVA实现的网络服务器文件同步」· Java 代码 · 共 43 行

package com.msd;

import java.util.HashMap;

public class SendFileThreadFactory {

	private static SendFileThreadFactory instance = null;
	private String[] serverAdd = null;
	private int[] port = null;

	private SendFileThreadFactory(String[] ipadd,int[] parr) {
		this.serverAdd = ipadd;
		this.port = parr;
	}
	
	public synchronized static void create(String[] ipadd,int[] parr) {
		if(instance == null)
			instance = new SendFileThreadFactory(ipadd,parr);
	} 
	
	public static SendFileThreadFactory getInstance() {
		if(instance == null)
			throw new NullPointerException("SendFileThreadFactory is null");
		return instance;
	}
	
	public void init() {
		for(int i = 0; i < serverAdd.length; i++) {
			addThread(i);	
		}
	}
	
	private void addThread(int i) { 
		SendFileThread ftd = new SendFileThread(serverAdd[i].trim(),port[i],i); 
		Thread t = new Thread(ftd);
		t.start();
	}
	
	public synchronized void ExceptionOut(int i) {
		addThread(i);
	}
	
}