package openminer;
import java.net.*;
import java.sql.*;

public class MinerThreadPool {
	private MinerThread[] m_MinerThreads;
	private boolean[] m_IsThreadUsed;
	private int m_MaxThread;
	
	public MinerThreadPool(int maxThread) {
		m_MinerThreads = new MinerThread[maxThread];
		m_IsThreadUsed = new boolean[maxThread];
		for(int i=0;i<maxThread; i++) {
			m_MinerThreads[i] = new MinerThread();
			m_MinerThreads[i].setRunning(false);
			m_MinerThreads[i].start();
			m_IsThreadUsed[i] = false;
		}
		m_MaxThread = maxThread;
	}
	
	public void connect(int index, Connection conn) throws Exception {
		m_MinerThreads[index].connect(conn);
	}
	
	public void setSocket(int index, Socket s) {
		m_MinerThreads[index].setSocket(s);
	}
	
	public void destroyAll() throws Exception {
		for(int i=0;i<m_MaxThread; i++) {
			m_MinerThreads[i].exit();
		}
	}
	
	public synchronized MinerThread openMinerThread() {
		for(int i=0; i < m_MaxThread; i++) {
			if(!m_IsThreadUsed[i]) {
				m_IsThreadUsed[i] = false;
				return m_MinerThreads[i];
			}
		}
		return null;
	}
	
	public synchronized void closeMinerThread(MinerThread thread) {
		for(int i=0; i< m_MaxThread; i++) {
			if(m_MinerThreads[i] == thread && m_IsThreadUsed[i]== true) {
				m_IsThreadUsed[i] = false;
				return;
			}
		}
	}
	
	
	
	
}