多线程并发 - ITeye问答

0 0

多线程并发5

实现的功能如下，相约一起去烧烤：可能其中一方先到，另一方后到。两个都到了之后，才一起去。
使用 java.util.concurrent.CountDownLatch 怎么保证两个线程同时到了，注意，这里有一个身份的判断，两个是之前相约的两个人？
如果是，两个共同的CountDownLatch分别调用countDown()方法，最后 await()等待确认两个都到了，才一起去。

这里关键怎么处理身份判断和两个人一个countDownlatch 这个要怎么处理？

问题补充：

OpenMind 写道

你是不是想干下面的事情啊？


public class Person extends Thread {
	static Random random = new Random();
	private String name;
	private CountDownLatch cdl;

	public Person(String name, CountDownLatch cdl) {
		super();
		this.name = name;
		this.cdl = cdl;
	}

	public void walk() {
		try {
			// 每个人行走的时间随机,0-5秒
			Thread.sleep(Math.abs(random.nextInt() % 5000));
		} catch (InterruptedException e) {
			// ignore
		}
	}

	private void await() {
		cdl.countDown();
		try {
			cdl.await();// 如果有人每到，一直到所有人到了以后在继续
		} catch (InterruptedException e) {
		}
	}

	public void 烧烤() {
		System.out.println(name + " starting 烧烤");
		try {
			Thread.sleep(1000);
		} catch (InterruptedException e) {
			// ignore
		}
	}

	public void run() {
		// 走一段时间
		walk();
		// 等等看还有没有人每到，
		await();
		//
		烧烤();
	}

	public static void main(String[] args) {
		int personCount = 10;
		CountDownLatch cdl = new CountDownLatch(10);
		for (int i = 0; i < personCount; i++) {
			new Person("men " + i, cdl).start();
		}
	}

}

你这个这样处理我知道，关键是来到你面前的很多人，你怎么判断他是你的伙伴，两个人共用一个CountDownLatch或者其他的线程并发处理类来处理这个逻辑。

Java 多线程

2012年2月15日 10:12

shmily2038
1
1 1 3

2个答案按时间排序按投票排序

0 0

你是不是想干下面的事情啊？


public class Person extends Thread {
	static Random random = new Random();
	private String name;
	private CountDownLatch cdl;

	public Person(String name, CountDownLatch cdl) {
		super();
		this.name = name;
		this.cdl = cdl;
	}

	public void walk() {
		try {
			// 每个人行走的时间随机,0-5秒
			Thread.sleep(Math.abs(random.nextInt() % 5000));
		} catch (InterruptedException e) {
			// ignore
		}
	}

	private void await() {
		cdl.countDown();
		try {
			cdl.await();// 如果有人每到，一直到所有人到了以后在继续
		} catch (InterruptedException e) {
		}
	}

	public void 烧烤() {
		System.out.println(name + " starting 烧烤");
		try {
			Thread.sleep(1000);
		} catch (InterruptedException e) {
			// ignore
		}
	}

	public void run() {
		// 走一段时间
		walk();
		// 等等看还有没有人每到，
		await();
		//
		烧烤();
	}

	public static void main(String[] args) {
		int personCount = 10;
		CountDownLatch cdl = new CountDownLatch(10);
		for (int i = 0; i < personCount; i++) {
			new Person("men " + i, cdl).start();
		}
	}

}

2012年2月15日 15:17

OpenMind
704
0 1 13

添加评论

0 0

可以先为两人包装成一个组, 如 (伪码描述)
class Team {
CountDownLatch cdl = new CountDownLatch(2); // 这个组共同的countDownlatch
People p;// 这个组先到的那个人
}

然后用一个List记录所有已经到了一个人的组
List waitingTeams = [];

当一个人到的时候,遍历这个List 判断有没有同组人在等自己
如果没有: 说明自己是先到的, 建一个新的team并放到List里, 然后等待队友
如果有: 将team从List里删除, 然后唤醒队友, 继续
-----
其实我觉得应该用CyclicBarrier

2012年2月15日 12:52