Java 多線程練習

題目： 某公司組織年會,會議入場時有兩個入口,在入場時每位員工都能獲取一張雙色球彩票,假設公司有100個員工,利用多線程模擬年會入場過程,

並分別統計每個入口入場的人數,以及每個員工拿到的彩票的號碼。線程運行后打印格式如下：

編號為: 2 的員工 從后門 入場! 拿到的雙色球彩票號碼是: [17, 24, 29, 30, 31, 32, 07]

編號為: 1 的員工 從后門 入場! 拿到的雙色球彩票號碼是: [06, 11, 14, 22, 29, 32, 15]

//.....

從后門入場的員工總共: 13 位員工

從前門入場的員工總共: 87 位員工

 

分析： 兩個入口對應兩個線程，獲取彩票的方法覆寫Runnable接口的run方法實現，我把這個實現了Runnable接口的類稱作Paper類，里面用id字段記錄員工編號，並提供get，set方法。設置第3個線程來作為隨機控制100個員工進出哪個入口，因為是員工進入了入口，入口才相應彩票方法，所以我用了等待喚醒機制(這里要注意，這個等待喚醒機制必須要在同步塊中，還要用同一把鎖。)

 

代碼：

class Paper implements Runnable {

    boolean bFlag = false;

    private int id;

    public void setId(int id) {

        this.id = id;
    }

    public int getId() {
        return this.id;
    }

    public String position;

    private List<String> listPosCount = new ArrayList<String>();

    private HashMap<Integer, int[]> dic = new HashMap<Integer, int[]>();

    private List<Integer> myList = new ArrayList<Integer>();

    private int[] getNumbers(int size) {

        int numbers[] = new int[size];

        for (int i = 0; i < size;) {

            boolean flag = false;

            numbers[i] = (int) (Math.random() * 100);

            for (int j = 0; j < i; j++) {

                if (numbers[j] == numbers[i]) {

                    flag = true;

                    break;

                }
            }

            if (flag == true) {

                continue;
            }

            i++;
        }
        return numbers;
    }

    @Override
    public void run() {
        synchronized (this) {
            while (myList.size() < 100) {

                while (!bFlag) {

                    try {

                        this.wait();

                    } catch (InterruptedException e) {

                        e.printStackTrace();
                    }
                }        
            
                this.bFlag = false;
                
                if (!myList.contains(id)) {

                    myList.add(id);
                    if (position == "qian門" || position == "后門")
                        listPosCount.add(position);

                    int nums[] = getNumbers(7);

                    dic.put(id, nums);

                    System.out
                            .println("編號為: " + id + " 的員工 從" + position + " 入場! 拿到的雙色球彩票號碼是:" + Arrays.toString(nums));

                } else {

                    
                }
                this.notifyAll();
            }

            int a = 0, b = 0;
            for (String str : listPosCount) {

                if (str == "后門")
                    a++;
                if (str == "qian門")
                    b++;

            }
            System.out.println("從后門入場的員工總共:" + a + " 位員工");
            System.out.println("從后門入場的員工總共:" + b + " 位員工");

        }
    }
}

//--------------------------------------------------------------------------------

//測試main函數

public class ThreadLearn2 {

	public static void main(String[] args) {

		Paper p = new Paper();

		Thread th1 = new Thread(p);
		Thread th2 = new Thread(p);

		Runnable run1 = new Runnable() {

			@Override
			public void run() {
				synchronized (p) {
					
				
					List<Integer> list = new ArrayList<Integer>();

					while (list.size() < 100) {
						int i = (int) (Math.random() * 100);

						if (list.indexOf(i) == -1) {

							p.setId(i);

							list.add(i);

							p.bFlag = true;

							int num = (int) (Math.random() * 100) % 2;

							if (num == 1) {

								p.position = "后門";
							} else {
								p.position = "qian門";

							}
							p.notifyAll();
							
							while (p.bFlag) {

								try {

									p.wait();

								} catch (InterruptedException e) {

									e.printStackTrace();
								}
							}

						}

					}

				}
			}

		};

		Thread th3 = new Thread(run1);

		th1.start();
		th2.start();
		th3.start();

	}

}