本文共 1681 字,大约阅读时间需要 5 分钟。
1 可以用java.util.concurrent.atomic 包下的AtomicInteger。。。 来实现
2 用sychronized来实现方法同步
3用ReentrantLock 实现(上锁lock(),解锁unlock())
优点(1)等待可以中断tryLock(timeout,unit),尝试获得锁 并设置等待时间;
(2)可以设置公平锁
4ReentrantLock 配合Condition来实现精细化的同步控制 Condition.await();Condition.signal()
多线程 一种异步进行的方式
1 继承Thread 有run 和start两种方式唤醒线程.
线程的状态:new 通过调start()方法 线程进入runnable状态. 等待CPU分配时间执行线程.分配到时间后变成running.可以通过sleep()线程blocked状态,sleep时间结束,进入runnable状态,此时不是立马执行,需要等待CPU分配时间.正在执行的running可以Synchronized使其进入blocked状态,然后再进入runnable状态等待CPU分配时间.
wait/notify必须存在于synchronized块中。并且,这三个关键字针对的是同一个监视器(某对象的监视器)。使用了notify()方法,不会对其它对象中的wait()方法起作用.
如果直接执行run方法是同步(主线程调用),按编码顺序执行;start方法是让系统来找一个时间来调用run方法(子线程调用),
2线程池开启多线程例子:
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
@Resource(name = "threadPoolExecutor")
private ThreadPoolTaskExecutor threadPoolExecutor;
final CountDownLatch countDownLatch = new CountDownLatch(10);
线程池 开启1
private void getInventoryInNewThread(final CountDownLatch countDownLatch, final String a,
final String a, final Object c) { threadPoolExecutor.execute(new Runnable() { @Override public void run() { try { 业务代码 } catch (Exception e) { logger.error("getInventoryInNewThread error", e); } finally { countDownLatch.countDown(); } } }); }线程池 开启2
与上面类似
try {
countDownLatch.await(); } catch (InterruptedException e) { Thread.currentThread().interrupt(); }
3学习参考:
4 interrupted()在检测一次之后就把标记给去掉,但是isInterrupted()却不会去掉这个中断标记。interrupt()是不能够停止线程的。
5 多线程停止方法(1)伪停止法(2)异常法 throw new RuntimeException(); 不要捕获这个异常;return 异常
6
局部变量线程安全的,实例变量不是线程安全的(理解局部变量 和实例变量)
7同一个对象 无论这个对象多少个方法 加了synchronized ,不同的线程访问的是不同的加了synchronized的方法,也必须一个线程执行完了才能轮到另一个线程去执行.(对象锁只有一个)
8同步是不具备继承性的 9当异常出现时,线程自动释放锁