Java 同時プログラミングとスレッド セーフの基本の概要

package ThreadSafe;public class Account {
	//账号
	private String actno;
	//余额
	private double balance;
	
	public Account(String actno, double balance) {
		super();
		this.actno = actno;
		this.balance = balance;
	}
	public String getActno() {
		return actno;
	}
	public void setActno(String actno) {
		this.actno = actno;
	}
	public double getBalance() {
		return balance;
	}
	public void setBalance(double balance) {
		this.balance = balance;
	}
	//取款的方法
	public void withdraw(double money){
		//t1和t2并发执行这个方法（t1和t2是两个栈 ，两个栈操作堆中同一个对象）
		//取款之前的余额
		double before=this.getBalance();
		//取款之后的余额
		double after=before-money;
		//模拟一下网络延迟，会出现问题
		try {
			Thread.sleep(1000);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		//更新余额
		//思考：t1执行到这里了，但还没有来得及执行这行代码，t2线程进来withdraw方法了，此时一定出问题
		this.setBalance(after);
	}}AccountThread类public class AccountThread extends Thread{
	//两个线程必须共享一个账户对象
	private Account act;
	//通过构造方法传递过来账户对象
	public AccountThread(Account act) {
		this.act = act;
	}
	@Override
	public void run() {
		//假设取款5000
		double money=5000;
		//多线程执行这个方法
		act.withdraw(money);
		System.out.println(Thread.currentThread().getName()+"账户"+act.getActno()+"取款成功"+act.getBalance());
	}}

public class Test {
	public static void main(String[] args) {
		//创建账户对象
		Account act=new Account("act-001",10000);
		//创建两个线程
		Thread t1=new AccountThread(act);
		Thread t2=new AccountThread(act);
		
		t1.setName("t1");
		t2.setName("t2");
		//启动两个线程执行
		t1.start();
		t2.start();
	}}

		synchronized(this){
			double before=this.getBalance();
			double after=before-money;
			try {
				Thread.sleep(1000);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			this.setBalance(after);
		}

//多线程执行这个方法//synchronized(this)//这里的this是AccountThread对象，这个对象不共享。synchronized(act){
			act.withdraw(money);
			System.out.println(Thread.currentThread().getName()+"账户"+act.getActno()+"取款成功，余额："+act.getBalance());}

public class exam01 {
	public static void main(String[] args) {
		MyClass mc=new MyClass();
		Thread t1=new MyThread(mc);
		Thread t2=new MyThread(mc);
		t1.setName("t1");
		t2.setName("t2");
		t1.start();
		try {
			Thread.sleep(1000);		//这个睡眠的作用是：为了保证t1线程先执行
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		t2.start();
	}}class MyThread extends Thread{
	private MyClass mc;
	public MyThread(MyClass mc) {
		super();
		this.mc = mc;
	}
	public void run(){
		if(Thread.currentThread().getName().equals("t1")){
			mc.dosome();
		}
		if(Thread.currentThread().getName().equals("t2")){
			mc.doOther();
		}
	}
	}class MyClass{
	public synchronized void dosome(){
		System.out.println("doSome begin");
		try {
			Thread.sleep(1000);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		System.out.println("doSome end");
	}
	public void doOther(){
		System.out.println("doOther begin");
		System.out.println("doOther end");
	}}

	public synchronized void doOther(){
		System.out.println("doOther begin");
		System.out.println("doOther end");
	}

MyClass mc1=new MyClass();MyClass mc2=new MyClass();Thread t1=new MyThread(mc1);Thread t2=new MyThread(mc2);

MyClass mc1=new MyClass();MyClass mc2=new MyClass();Thread t1=new MyThread(mc1);Thread t2=new MyThread(mc2);public synchronized static void dosome(){
		System.out.println("doSome begin");
		try {
			Thread.sleep(1000);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		System.out.println("doSome end");
	}
	public synchronized static void doOther(){
		System.out.println("doOther begin");
		System.out.println("doOther end");
	}

public class DeadLock {
	public static void main(String[] args) {
		Object o1=new Object();
		Object o2=new Object();
		//t1线程和t2线程共享o1,o2
		Thread t1=new MyThread1(o1,o2);
		Thread t2=new MyThread2(o1,o2);
		t1.start();
		t2.start();
	}}class MyThread1 extends Thread{
	Object o1;
	Object o2;
	public MyThread1(Object o1,Object o2){
		this.o1=o1;
		this.o2=o2;
	}
	@Override
	public void run() {
		synchronized (o1) {
			try {
				Thread.sleep(1000);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			synchronized (o2) {
				
			}
		}
	}}class MyThread2 extends Thread{
	Object o1;
	Object o2;
	public MyThread2(Object o1,Object o2){
		this.o1=o1;
		this.o2=o2;
	}
	@Override
	public void run() {
		synchronized (o2) {
			try {
				Thread.sleep(1000);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			synchronized (o1) {
				
			}
		}
	}}

package testThread;/*
实现守护线程
 * */
	public class ThreadTest13 {

	public static void main(String[] args) {
		// TODO Auto-generated method stub
		Thread t=new BakDataThread();
		t.setName("备份数据的线程");
		//启动之前，将线程设置为守护线程
		t.setDaemon(true);
		t.start();
		//主线程：主线程是用户线程
		for(int i=0;i"+i);
			try {
				Thread.sleep(1000);
			} catch (Exception e) {
				// TODO: handle exception
			}
		}
	}}class BakDataThread extends Thread{
	@Override
	public void run() {
		int i=0;
		//即使是死循环，但由于该线程是守护者，当用户线程结束，守护线程自动终止
		while(true){
			System.out.println(Thread.currentThread().getName()+"---->"+(++i));
			try {
				Thread.sleep(1000);
			} catch (Exception e) {
				// TODO: handle exception
			}
			
		}
	}}

public class ThreadTest14 {
	public static void main(String[] args) throws Exception, ExecutionException {
		//第一步：创建一个未来任务类对象
		//参数非常重要，需要给一个callable接口的实现类对象
		FutureTask task=new FutureTask(new Callable(){
			@Override
			//call方法相当于是run方法，只不过这个有返回值，线程执行一个任务，执行之后可能会有一个执行结果。
			public Object call() throws Exception {
				System.out.println("call method begin");
				Thread.sleep(1000);
				System.out.println("call method begin");
				int a=100;
				int b=200;
				return a+b;			//自动装箱
			}		
		});
		//创建线程对象
		Thread t=new Thread(task);
		
		//启动线程
		t.start();
		
		//这里是main方法，这是在主线程中
		//在线程中，怎么获取t线程的执行结果
		//get方法的执行会导致当前线程阻塞
		Object obj=task.get();
		System.out.println("线程执行结果"+obj);
		//main方法这里的程序要想执行必须等待get()方法的结束
		//而get方法可能需要很久。因为get()方法是为了拿另一个线程的执行结果。
		//另一个线程的执行是需要时间的
		System.out.println("hello,world");
	}}

public class ThreadTest15 {
	public static void main(String[] args) {
		//创建一个仓库独享，共享的
		List list=new ArrayList();
		//创建两个线程对象
		//生产者线程
		Thread t1=new Thread(new Producer(list));
		//消费者线程
		Thread t2=new Thread(new Consumer(list));
		t1.setName("生产者线程");
		t2.setName("消费者线程");
		t1.start();
		t2.start();
	}}//生产线程class Producer implements Runnable{
	//仓库
	private List list;
	public Producer(List list) {
		this.list = list;
	}
	public void run() {
		//一直生产
		while(true){
			//给仓库对象list加锁
			synchronized (list) {
				if(list.size()>0){	//大于0说明仓库中已经有1个元素了
					//当前线程进入等待状态，并且释放list集合的锁
					try {
						list.wait();
					} catch (InterruptedException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
				}
				//程序能够执行到这里说明仓库是空的，可以生产
				Object obj =new Object();
				list.add(obj);
				System.out.println(Thread.currentThread().getName()+"---->"+obj);
				//唤醒消费者进行消费
				list.notifyAll();
			}
			
		}
	}}//消费线程class Consumer implements Runnable{
	//仓库
	private List list;
	public Consumer(List list) {
		this.list = list;
	}
	public void run() {
		//一直消费
		while(true){
			//给仓库对象list加锁
			synchronized (list) {
				if(list.size()==0){	//仓里已经空了
					try {
						//仓库已经空了
						//消费者线程等待，并释放掉list集合锁
						list.wait();
					} catch (InterruptedException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
				}
			}
			Object obj=list.remove(0);
			System.out.println(Thread.currentThread().getName()+"---->"+obj);
			//唤醒生产者生产
			list.notifyAll();
		}
	}}