package com.chess;

import java.io.IOException;

import java.io.OutputStream;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.ScheduledExecutorService;

import java.util.concurrent.TimeUnit;

import org.apache.log4j.Logger;

import org.apache.log4j.PropertyConfigurator;

import com.chess.command.StopCommand;

import com.chess.process.EngineProcess;

import com.chess.utilities.ChessEngineUtilities;

import com.chess.utilities.RobotUtilities;

public class StartChessEngine implements Runnable {

public static long requestTime = 0L;

public static boolean hasReturn = false;

private static Logger log ;

static {

PropertyConfigurator.configure("log4j.properties");

log= Logger.getLogger(RobotUtilities.class);

}

@Override

public void run() {

try {

while (true) {

// 处理准备开始，悔棋，求和。保证当前局面已到我方开始走棋,返回当前棋盘局面。

String fen = RobotUtilities.prepareToPlay();

// 通过fen获取最佳下法

String bestmove = ChessEngineUtilities.getBastMove(fen);

// 通过最佳下法操作鼠标点击

RobotUtilities.playByBestmove(bestmove);

}

} catch (Exception e) {

e.printStackTrace();

}

}

public static void main(String[] args) throws IOException {

// 使引擎在空闲状态

final OutputStream outputStream = EngineProcess.getOutputStream();

outputStream.write("ucci\r\n".getBytes());

outputStream.write("setoption Hash 256\r\n".getBytes());

outputStream.flush();

// 开始检测定时器，要注意根据限时设置时间，要不会影响引擎的棋力

ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);

executor.scheduleAtFixedRate(new StopCommand(), 0, 2000, TimeUnit.MILLISECONDS);

// 开始挂机线程

ExecutorService exec = Executors.newSingleThreadExecutor();

exec.execute(new StartChessEngine());

log.debug("engine starting success!!");

}

}