Java实现线程同步的方式

1、使用 synchronized 关键字实现线程之间的互斥操作。

public synchronized void set(int data) {...}      
public synchronized void get() {...}  

• 使用如上方式可以实现写数据和读数据都为互斥操作，但有的时候是需要读操作之间不需要互斥，写操作需要互斥，则可以使用如下lock锁的方式来实现。

2、使用Lock接口实现线程之间的互斥操作，注意使用这种方式需要手动释放锁，否则会造成死锁现象。

private ReadWriteLock rwl = new ReentrantReadWriteLock();   
    public void set(int data) {  
        rwl.writeLock().lock();// 取到写锁  
        try {  
            System.out.println(Thread.currentThread().getName() + "准备写入数据");  
            try {  
                Thread.sleep(20);  
            } catch (InterruptedException e) {  
                e.printStackTrace();  
            }  
            this.data = data;  
            System.out.println(Thread.currentThread().getName() + "写入" + this.data);  
        } finally {  
            rwl.writeLock().unlock();// 释放写锁  
        }  
    }   
    public void get() {  
        rwl.readLock().lock();// 取到读锁  
        try {  
            System.out.println(Thread.currentThread().getName() + "准备读取数据");  
            try {  
                Thread.sleep(20);  
            } catch (InterruptedException e) {  
                e.printStackTrace();  
            }  
            System.out.println(Thread.currentThread().getName() + "读取" + this.data);  
        } finally {  
            rwl.readLock().unlock();// 释放读锁  
        }  
    }  

使用lock则将读写操作分离开，很好的避免了读操作也互斥造成速度过慢的问题。

3、wait/notify/notifyAll

• wait/notify/notifyAll都只能在同步线程中使用。
• 当在多线程中判断条件是否变化时只能使用while来进行判断，不能使用if语句判断。

    private String lock;

    public Subtract(String lock) {
        super();
        this.lock = lock;
    }
...
    public void subtract() {
        try {
            synchronized (lock) {
                if(ValueObject.list.size() == 0) {//将这里的if改成while即可保证不出现越界异常!!!!
                    System.out.println("wait begin ThreadName="
                            + Thread.currentThread().getName());
                    lock.wait();
                    System.out.println("wait   end ThreadName="
                            + Thread.currentThread().getName());
                }
                ValueObject.list.remove(0);
                System.out.println("list size=" + ValueObject.list.size());
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
...

• Object类中与线程有关的方法:
  • notify/notifyAll
  • wait()/wait(long)
• java.lang.Thread中与线程相关的方法：
  • sleep()/sleep(long)
  • join()/suspend()/resume()等等
• 注意notify和wait的使用顺序
  假设在线程A中执行wait()，在线程B中执行notify()。但如果线程B先执行了notify()然后结束了，线程A才去执行wait()，那此时，线程A将无法被正常唤醒了

Summary
自己对线程进行的一些总结，其中有些代码来源于网上其他童鞋的资料，如有侵权请联系我，谢谢