java多线程(锁、线程池)

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class Test {
	public static void main(String[] args) {
		// 
		MyCount myCount = new MyCount("1234505454545", 500000);
		//创建锁 
		Lock lock = new ReentrantLock();
		//创建线程池 
		ExecutorService pool = Executors.newCachedThreadPool();
		// 
		User u1 = new User("A", myCount, -5000, lock);
		User u2 = new User("B", myCount, 6000， lock);
		User u3 = new User("C", myCount, -7000, lock);
		User u4 = new User("A", myCount, 100000, lock);
		//在线程池中执行各个用户的操作 
		pool.execute(u1);
		pool.execute(u2);
		pool.execute(u3);
		pool.execute(u4);
		//关闭线程池 
		pool.shutdown();
	}
}

/** 
 *  
 */
class User implements Runnable {
	private String name; //用户名 

	private MyCount myCount; //账户

	private int iocash; //操作金额

	private Lock myLock; //锁 

	User(String name, MyCount myCount, int iocash, Lock myLock) {
		this.name = name;
		this.myCount = myCount;
		this.iocash = iocash;
		this.myLock = myLock;
	}

	public void run() {
		//获取锁 
		myLock.lock();
		//执行现金业务 
		System.out.println(name + "正在操作" + myCount + "账户，金额为" + iocash
				+ "，当前金额为" + myCount.getCash());
		myCount.setCash(myCount.getCash() + iocash);
		System.out.println(name + "操作" + myCount + "账户成功，金额为" + iocash
				+ "，当前金额为" + myCount.getCash());
		//释放锁，
		myLock.unlock();
	}
}

/** 
 * 
 */
class MyCount {
	private String oid; //账号 

	private int cash; //账户余额 

	MyCount(String oid, int cash) {
		this.oid = oid;
		this.cash = cash;
	}

	public String getOid() {
		return oid;
	}

	public void setOid(String oid) {
		this.oid = oid;
	}

	public int getCash() {
		return cash;
	}

	public void setCash(int cash) {
		this.cash = cash;
	}

	@Override
	public String toString() {
		return "MyCount{" + "oid='" + oid + '\'' + ", cash=" + cash + '}';
	}
}