public class SortedPrintMore extends Thread{
//由于是不同的Thread n最好是共享
//无锁化
int i;
static int n;
static Lock lock = new ReentrantLock();
static Condition condition = lock.newCondition();
public SortedPrintMore(int n) {
this.i = n;
}
//使用lock和condition
@Override
public void run() {
while(true){
if(n %3 == i){
//抢到锁了
if(n>100) return;
lock.lock();
System.out.println(Thread.currentThread().getName()+" : "+n++);
try {
condition.signalAll();
condition.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
lock.unlock();
}
}
}
public static void main(String[] args) {
SortedPrintMore more1 = new SortedPrintMore(0);
SortedPrintMore more2 = new SortedPrintMore(1);
SortedPrintMore more3 = new SortedPrintMore(2);
more1.start();
more2.start();
more3.start();
}
}
相关文章
- 02-19JUC-8-lock和Condition使用
- 02-19Lock和Condition实现等待通知
- 02-19第二部分:并发工具类15->Lock和condition(下)
- 02-19按序打印_lock和condition
- 02-19一手遮天 Android - 锁和并发处理: Lock 演示 Condition 的 await() signal() signalAll() 的使用
- 02-19按序打印_lock和condition
- 02-19基于std::mutex std::lock_guard std::condition_variable 和std::async实现的简单同步队列
- 02-19【Java并发系列04】线程锁synchronized和Lock和volatile和Condition
- 02-19多线程09-Lock和Condition
- 02-19【Java并发编程实战】(十一):Lock和Condition