我想模擬某種「服務器」。我有一個名爲Server的類擴展了Thread。我有一個從1到1,000,000的循環,如果它取決於有多少服務器,我想在每次循環時啓動一個新線程,以便服務器接收「請求」執行它並且將服務器標記爲繁忙,然後停止此線程標記服務器爲不忙,並等待新的「請求」。Java:如何啓動同一對象的另一個線程?
目前我得到java.lang.IllegalThreadStateException
從我讀的是因爲我試圖啓動相同的線程。我怎樣才能解決這個問題並實現我想要的?
Server.java
public class Server extends Thread
{
boolean isBusy = false;
int executionTime;
int serverId;
List<Request> requests = new ArrayList<Request>();
Request currentRequest;
public Server(int requiredServerId,int requiredExecutionTime)
{
this.serverId = requiredServerId;
this.executionTime = requiredExecutionTime;
}
@Override
public void run()
{
isBusy = true;
for(int time = 1; time <= executionTime; time++)
{
if(time == executionTime)
{
isBusy = false;
currentRequest.setFinish();
break;
}
}
}
public void fetch(Request request)
{
requests.add(request);
currentRequest = request;
}
}
Main.java
// Create Servers
List<Server> servers = new ArrayList<Server>();
for(int i = 0; i < numberOfServers; i++)
{
servers.add(new Server(i, executionTime));
}
// Create Queue
List<Integer> queue = new ArrayList<Integer>();
for(int time = 1; time <= runningTime; time++)
{
if(time % arrivalTime == 0)
{
if(queue.size() <= queueSize)
{
queue.add(time);
}
else
{
rejectedRequests += 1;
}
}
if(!queue.isEmpty())
{
for(Server server : servers)
{
if(server.isBusy == false)
{
Request request = new Request(queue.get(0));
queue.remove(0);
server.fetch(request);
server.start();
}
break;
}
}
}