-4

私は Threads に慣れていないので、このエラーを修正する必要があります。

申し訳ありませんが、これは私がしなければならないことです:

この Web アプリケーションは、1000 ゲームを実行し、出力結果を表示する必要があります。

重ねてお詫び申し上げます。

ありがとう

/**
 * 
 * Automatic agent to play 1000 games
 * 
 */
public class AutoPlayer implements Runnable {

    private RequestDispatcher requestDispatcher;

    public AutoPlayer(RequestDispatcher requestDispatcher) {
    this.requestDispatcher = requestDispatcher;
    }


    public static void main(String[] args) {

    HashMap<String, Game> games = new HashMap<String, Game>();

    RequestDispatcher rd = new RequestDispatcher(games);

    Vector<Thread> threads = new Vector<Thread>();

    for (int i = 0; i < 10; i++) {
        AutoPlayer autoPlayer = new AutoPlayer(rd);
        Thread thread = new Thread(autoPlayer);
        threads.add(thread);
        thread.start();
    }

    for (int i = 0; i < threads.size(); i++) {
        try {
        threads.get(i).join();
        } catch (InterruptedException e) {
        e.printStackTrace();
        }
    }

    }



    @Override
    public void run() {

    PlayResponse response = null;

    for (int i = 0; i < 1000; i++) {
        byte[] numbers = requestDispatcher.cardRequest();

        try {
        response = new PlayResponse();
        requestDispatcher.process("Lucky", 10, numbers, response);
        } catch (UnknownGameException e) {
        e.printStackTrace();
        }

        if (response != null) {
        System.out.println("[" + Thread.currentThread() + "] total requests:" + requestDispatcher.generatedCards);
        }
    }
    }

}



public class Game {

    private String name;
    private int gamesPlayed;

    public String getName() {
    return name;
    }

    public void setName(String name) {
    this.name = name;
    }

    public int getGamesPlayed() {
    return gamesPlayed;
    }

    public void setGamesPlayed(int gamesPlayed) {
    this.gamesPlayed = gamesPlayed;
    }

}



/**
 * 
 * Response to a Play request
 * 
 */
public class PlayResponse {

    private boolean error;
    private long win;

    public boolean isError() {
        return error;
    }
    public void setError(boolean error) {
        this.error = error;
    }
    public long getWin() {
        return win;
    }
    public void setWin(long win) {
        this.win = win;
    }

}




/**
 * 
 * Object that processes play requests, calculates outcomes and returns results.
 * 
 */
public class RequestDispatcher {

    List<String> list = Arrays.asList("Lucky", "Happy", "Extra");

    final int CARD_SIZE = 15;

    public String GAME_UNAVAILABLE = "Error: Game not available";

    Map<String, Game> games;

    long generatedCards;

    Logger logger = Logger.getLogger(getClass().getName());

    Random r = new Random();

    public RequestDispatcher(HashMap<String, Game> games) {
    this.games = games;

    }

    public byte[] cardRequest() {
    byte[] result = createCard();
    generatedCards++;

    return result;
    }

    private byte[] createCard() {

    byte[] result = new byte[CARD_SIZE];

    r.nextBytes(result);

    return result;
    }

    public void process(String s, int i, byte[] bb, PlayResponse pr0) throws UnknownGameException {

    if (!list.contains(s)) {
        logger.log(Level.SEVERE, GAME_UNAVAILABLE);
        throw new UnknownGameException(GAME_UNAVAILABLE);
    }

    Game game = games.get(s);

    if (game != null) {
        game.setGamesPlayed(game.getGamesPlayed() + 1);
    } else {
        Game g = new Game();
        g.setName(s);
        games.put(s, g);
        g.setGamesPlayed(0);
    }

    pr0.setWin(r.nextInt(3) * i);
    pr0.setError(false);

    }
}


public class UnknownGameException extends Exception {

    private static final long serialVersionUID = 2380720995275983122L;

    public UnknownGameException(String s) {
    super(s);
    }
}
4

3 に答える 3

1

run10 個のスレッドを使用して 1000 回実行する必要がある場合は、次のオプションを検討してください。

  1. 各スレッドを 100 回実行します。
  2. カウンターが 1000 に達したときに実行を停止するスレッド間で共有される静的カウンターを使用しますAtomicInteger
于 2013-05-21T12:45:02.043 に答える
0

コードでは、メインに 10 個のスレッドを作成しています。スレッド数を変更し、共有フィールドとメソッドに同期を使用するだけです。

于 2013-05-21T13:00:17.027 に答える