Совместное использование объекта между двумя потоками и основной программой - PullRequest
Новая
       3

Совместное использование объекта между двумя потоками и основной программой

10 голосов
/ 31 августа 2010

Я новичок в Java и посещаю курс по параллельному программированию.Я отчаянно пытаюсь получить минимальный рабочий пример, который может помочь продемонстрировать изученные мной концепции, такие как использование синхронизированного ключевого слова и разделение объекта между потоками.Были поиски, но не могли получить базовые рамки.Java программисты, пожалуйста, помогите.

Ответы [ 2 ]

8 голосов
/ 31 августа 2010

Простой пример. Надеюсь, вы любите футбол (или футбол). :) 

public class Game {

 public static void main(String[] args) {
  Ball gameBall = new Ball();
  Runnable playerOne = new Player("Pasha", gameBall);
  Runnable playerTwo = new Player("Maxi", gameBall);

  new Thread(playerOne).start();
  new Thread(playerTwo).start();
 }

}

public class Player implements Runnable {

 private final String name;
 private final Ball ball;

 public Player(String aName, Ball aBall) {
  name = aName;
  ball = aBall;
 }

 @Override
 public void run() {
  while(true) {
   ball.kick(name);
  }
 }

}

public class Ball {

private String log;

 public Ball() {
  log = "";
 }

 //Removing the synchronized keyword will cause a race condition.
 public synchronized void kick(String aPlayerName) {
  log += aPlayerName + " ";
 }

 public String getLog() {
  return log;
 }

}
5 голосов
/ 31 августа 2010

Вот очень наглядный пример разделения массива между двумя потоками. Обычно вы видите все нули, но иногда все становится странным, и вы видите другие цифры. 

final int[] arr = new int[100];
Thread one = new Thread() {
    public void run() {
        // synchronized (arr) {
            for (int i = 0; i < arr.length * 100000; i++) {
                arr[i % arr.length]--;
            }
        // }
    }
};
Thread two = new Thread() {
    public void run() {
        // synchronized (arr) {
            for (int i = 0; i < arr.length * 100000; i++) {
                arr[i % arr.length]++;
            }
        //}
    }
};
one.start();
two.start();
one.join();
two.join();
for (int i = 0; i < arr.length; i++) {
    System.out.println(arr[i]);
}

Но, если вы синхронизируете на arr в цикле, вы всегда увидите все 0 s в распечатке. Если вы раскомментируете синхронизированный блок, код будет работать без ошибок.

...