【java并发】多个线程间共享数据

先看一个多线程间共享数据的问题:

设计四个线程,其中两个线程每次对data增加1,另外两个线程每次对data减少1。

从问题来看,很明显涉及到了线程间通数据的共享,四个线程共享一个data,共同操作一个data。我们先把上面这个问题放在一边,慢慢分析多个线程之间共享数据的一些情况,从最简单开始,分类分析完了后,到时候也好解决上面这个问题了。

1. 每个线程执行的任务相同
   这是最简单的一种情况,比如卖票,几个线程共同操作记录票数的那个变量,任务都是使它减一。针对这种情况,我们只需要写一个类实现Runnable接口即可,在run()方法中对这个票进行减一,然后将这个Runnalbe扔给多个线程去执行,自然它们就操作同一个data了。看一下代码: ```java public class MultiThreadShareData {
public static void main(String[] args) {
	
	ShareData task = new ShareData(); //一个类实现了Runnable接口
	
	for(int i = 0; i < 4; i ++) {	//四个线程来卖票		
		new Thread(task).start();
	}

}

}

class ShareData implements Runnable {

private int data = 100;
@Override
public void run() { //卖票,每次一个线程进来,先判断票数是否大于0

// while(data > 0) { synchronized(this) { if(data > 0) { System.out.println(Thread.currentThread().getName() + ": " + data); data–; } } // } } }

  <font size=3>这很好理解,也很容易实现,四个线程卖了4张票。运行结果为:
>Thread-0: 100
Thread-3: 99
Thread-2: 98
Thread-1: 97

<table><tr><td bgcolor=#F5FFFA><h2><strong>2. 每个线程执行不同的任务</h3></td></tr></table>
  <font size=3>就如上面那个题目所描述的,两个线程执行data增,两个线程执行data减。针对这种情况,我们要实现两个Runnable了,因为很明显有两个不同的任务了,一个任务执行data增,另一个任务执行data减。为了便于维护,可以将两个任务方法放到一个类中,然后将data也放在这个类中,然后传到不同的Runnable中,即可完成数据的共享。如下:
```java
public class MultiThreadShareData {

	public static void main(String[] args) {
		
		ShareData task = new ShareData(); //公共数据和任务放在task中

		for(int i = 0; i < 2; i ++) { //开启两个线程增加data
			
			new Thread(new Runnable() {
				
				@Override
				public void run() {
					task.increment();
				}
			}).start();
		}
		
		for(int i = 0; i < 2; i ++) { //开启两个线程减少data
			
			new Thread(new Runnable() {
				
				@Override
				public void run() {
					task.decrement();
				}
			}).start();
		}			
	}
}	


class ShareData /*implements Runnable*/ {

	private int data = 0;
	public synchronized void increment() { //增加data
		System.out.println(Thread.currentThread().getName() + ": before : " + data);
		data++;
		System.out.println(Thread.currentThread().getName() + ": after : " + data);
	}
	
	public synchronized void decrement() { //减少data
		System.out.println(Thread.currentThread().getName() + ": before : " + data);
		data--;
		System.out.println(Thread.currentThread().getName() + ": after : " + data);
	}
}

看一下打印结果:

Thread-0: before : 0 Thread-0: after : 1 Thread-1: before : 1 Thread-1: after : 2 Thread-2: before : 2 Thread-2: after : 1 Thread-3: before : 1 Thread-3: after : 0

相关阅读:http://blog..net/column/details/bingfa.html



—–乐于分享,共同进步! —–更多文章请看:http://blog..net/eson_15

经验分享 程序员 微信小程序 职场和发展