多线程的协调代码,Java代码库,德仔网

代码语言

代码分类

【Java】多线程的协调

作者:yangzhiyong / 发布于2013/2/1/ 530

package org.yang;

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class Test {
	public static void main(String[] args) {

		final Businese b = new Businese();
		new Thread(new Runnable() {

			public void run() {

				while (true) {
					b.sub();
				}
			}
		}).start();

		new Thread(new Runnable() {

			public void run() {

				while (true) {
					b.sub2();
				}
			}
		}).start();

		new Thread(new Runnable() {

			public void run() {

				while (true) {
					b.main();
				}
			}
		}).start();
	}
}

class Businese {
	Lock lock = new ReentrantLock();
	Condition sub1Condition = lock.newCondition();
	Condition sub2Condition = lock.newCondition();
	Condition mainCondition = lock.newCondition();
	int isWho = 1;

	public void sub() {
		lock.lock();
		try {
			while (isWho != 2) {
				try {
					sub1Condition.await();
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
			System.out.println("老二在运行");
			this.isWho = 3;
			sub2Condition.signal();
		} finally {
			lock.unlock();
		}
	}

	public void sub2() {
		lock.lock();
		try {
			while (isWho != 3) {
				try {
					sub2Condition.await();
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
			System.out.println("老三在运行");
			this.isWho = 1;
			mainCondition.signal();
		} finally {
			lock.unlock();
		}
	}

	public void main() {
		lock.lock();
		try {
			while (this.isWho != 1) {
				try {
					mainCondition.await();
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
			System.out.println("老大在运行");
			this.isWho = 2;
			sub1Condition.signal();
		} finally {
			lock.unlock();
		}
	}
}

评论列表

本站所提供的代码，版权归原作者所有，若有侵犯作者版权，请与我们联系，我们将立即删除或修改。谢谢!
本站所有代码发布及提供者。

试试其它关键字

　多线程　

同语言下

可能有用的

yangzhiyong贡献的其它代码(2)