进程：任务任务并发执行是一个宏观概念，微观上是串行的。进程的调度是有OS负责的（有的系统为独占式，有的系统为共享式，根据重要性，进程有优先级）。 由OS将时间分为若干个时间片。JAVA在语言级支持多线程。分配时间的仍然是OS。 1package TomTexts;2 3publicclass TomTexts_21 {4publicstaticvoid main(String args[])5 {6int data1[]={2,4,6,8,10,12};7int data2[]={1,0,2,4,3};8try 9 { 10for(int i=0;i<data1.length...
假设现在系统有两个线程，这两个线程分别代表存款者和取钱者——现在假设系统有一种特殊的要求，系统要求存款者和取钱者不断地重复存款、取钱的动作。而且要求每当存款者将钱存入指定账户后，取钱者就立即取出该笔钱。不允许存款者连续两次存钱，也不允许取钱者连续两次取钱。为了实现这种功能，可以借助Object类提供的wait()、notify()、notifyAll() 3 个方法，这3个方法并不属于Thread类，而是属于Object类。但这3 个方法必须由同...
题目要求:有4个线程，其中两个线程每次对x加1，另外两个每次对x减1，如何实现？ 分析: x就是这4个线程要处理的共享数据，不同种线程有不同的处理方式，但操作的数据是共同的，联想到“窗口买票问题”，但是卖票只是单纯的减。 所以，多个线程访问共享对象或数据的方式，先看，如果每个线程执行的代码相同，那么就可以使用同一个Runnable对象，这个对象中有被共享的数据，如买票问题。如果每个线程执行的代码不同，肯定需要不用...
一、创建线程的三种方式第一种publicclass App {publicstaticvoid main(String[] args) {Thread thread = new Thread(() -> {while (true) {System.out.println("testThread");}});thread.start();} }第二种publicclass App {publicstaticvoid main(String[] args) {Thread thread = new Thread(new Runnable() {@Overridepublicvoid run() {while (true) {System.out.println("testThread");}}});thread.start();} }第二种和第一种...
可见性 所谓可见性，指的是当一个线程修改了对象的状态后，其他线程能够看到该对象发生的变化。在单线程环境下，向某个变量写入值，然后在后面的操作再读取，在这个过程中该变量的值对该线程来说总是可见。但是，在多线程环境下，可见性就不一定等到保证，例如，对于一个共享变量 share = 0 来说，线程1和线程2都进行share++ 操作，但是最终share 的结果并不一定是2。先看看一段代码publicclass NoVisibility {privatestaticboo...
java并发编程笔记（九）——多线程并发最佳实践使用本地变量使用不可变类最小化锁的作用域范围使用线程池Executor,而不是直接new Thread执行宁可使用同步也不要使用线程的wait和notify使用BlockingQueue实现生产-消费模式使用并发集合而不是加了锁的同步集合（比如Collections.synchronized这些集合尽量避免使用，应该用J.U.C中提供的专门的同步集合）使用Semaphore创建有界的访问宁可使用同步代码块，也不要使用同步的方法避免使用...
学习这个很长时间了一直没有去做个总结，现在大致总结一下并发包的线程池。首先，任何代码都是解决问题的，线程池解决什么问题？如果我们不用线程池，每次需要跑一个线程的时候自己new一个，会导致几个问题：1，不好统一管理线程和它们的相互之间的依赖关系，尤其是有的程序要做的事情很多的时候，线程的处理就显得很杂乱，更雪上加霜的是，线程本身就是不可预期的，不是说先跑的线程就一直在后跑的线程前面，一旦形成复杂的依赖关...
1. sleep()介绍sleep() 定义在Thread.java中。sleep() 的作用是让当前线程休眠，即当前线程会从“运行状态”进入到“休眠(阻塞)状态”。sleep()会指定休眠时间，线程休眠的时间会大于/等于该休眠时间；在线程重新被唤醒时，它会由“阻塞状态”变成“就绪状态”，从而等待cpu的调度执行。 2. sleep()示例下面通过一个简单示例演示sleep()的用法。 1 // SleepTest.java的源码2 class ThreadA extends Thread{3 public ThreadA(St...
一：多线程安全问题###1 引入/** 多线程并发访问同一个数据资源* 3个线程,对一个票资源,出售*/publicclass ThreadDemo {publicstaticvoid main(String[] args) {//创建Runnable接口实现类对象Tickets t = new Tickets();//创建3个Thread类对象,传递Runnable接口实现类Thread t0 = new Thread(t);Thread t1 = new Thread(t);Thread t2 = new Thread(t);t0.start();t1.start();t2.start();}}/** 通过线程休眠,出现安全问题*/publicc...
花10分钟认真的阅读一篇文章，会有意想不到的收获在学习java多线程的过程中，我们能一定见过sleep和wait这两个方法，这两个方法都是多线程中经常使用的方法，并且它们都可以让当前线程停下来。可是你知道吗？这两个方法其实有很大的差别。要想弄懂这两个方法的差别，我们可以先简单地看一下多线程的运行状态 New:初始状态，线程被创建，没有调用start（）Runnable:运行状态，Java线程把操作系统中的就绪和运行两种状态统一称为“运...
Java并发编程：线程池的使用 在前面的文章中，我们使用线程的时候就去创建一个线程，这样实现起来非常简便，但是就会有一个问题： 如果并发的线程数量很多，并且每个线程都是执行一个时间很短的任务就结束了，这样频繁创建线程就会大大降低系统的效率，因为频繁创建线程和销毁线程需要时间。 那么有没有一种办法使得线程可以复用，就是执行完一个任务，并不被销毁，而是可以继续执行其他的任务？ 在Java中可以通过线程...
1.Object类中的wait()/notify()/notifyAll()wait()： 让当前线程处于Waiting状态并释放掉持有的对象锁，直到其他线程调用此对象的线程notify()/notifyAll()方法，当前线程被唤醒进入Runnable状态 。 wait(long timeout)：让当前线程处于Timed Waiting状态并释放掉持有的对象锁，直到其他线程调用此对象的线程notify()/notifyAll()方法或者时间到期，当前线程被唤醒进入Runnable状态 。 wait(long timeout, int nanos) ：让当前线程...
最近项目中进行告警模块性能优化，不少地方使用了线程池技术，整理总结如下。package com.coshaho.threadpool;import java.util.concurrent.BlockingQueue; import java.util.concurrent.Executors; import java.util.concurrent.RejectedExecutionHandler; import java.util.concurrent.ThreadFactory; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit;/*** 线程池学习* @author coshaho*...
线程的生命周期新建(New)、就绪(Runnable)、执行(Running)、阻塞(Blocked)、死亡(Dead)新建状态当程序使用 new 关键字创建了一个线程之后，该线程就处于新建状态，此时仅由 JVM 为其分配内存，并初始化其成员变量的值。就绪状态当线程对象调用了 start()方法之后，该线程处于就绪状态。 Java 虚拟机会为其创建方法调用栈和程序计数器，等待调度运行。运行状态如果处于就绪状态的线程获得了 CPU，开始执行 run()方法的线程执行体，则...
Linux 操作系统中创建线程的方式int pthread_create(pthread_t *thread, const pthread_attr_t *attr, void *(*start_routine) (void *), void *arg); 参数名参数定义参数解释pthread_t *thread传出参数，调用之后会传出被创建线程的idconst pthread_attr_t *attr线程属性一般传 NULL，保持默认属性void *(*start_routine) (void *)线程启动后的主体函数void *arg主体函数的参数#include <pthread.h> #include <stdio.h>pthread_t ...