java并发学习--第一章 线程的创建
2024-09-03 07:28:27
所谓的并发就是指一个时间段中有几个程序都处于已启动运行到运行完毕之间,且这几个程序都是在同一个处理机上运行,但任一个时刻点上只有一个程序在处理机上运行。所以我们看似几个线程在同时进行,其实在操作系统中实际只会运行一个线程,并发过程就是快速切换线程的执行过程。
一、java中自带的线程创建方式
1.通过基础Thread
类,实现其run方法,完成线程创建
public class OneThread extends Thread { //run方法就是线程要执行的方法
public void run(){
System.out.println("这是一个线程");
} public static void main(String[] args) {
OneThread oneThread=new OneThread();
//通过线程的实例调用start方法,执行线程run方法
oneThread.start();
} }
2.通过声明Runnable 接口,实现run方法,创建线程
public class ThreadDemo implements Runnable { @Override
public void run() {
System.out.println("这是Runnable接口实现的线程");
} public static void main(String[] args) {
//先创建线程的实例
ThreadDemo threadDemo = new ThreadDemo();
//将线程放入thread方法中
Thread thread = new Thread(threadDemo);
//启动线程
thread.start(); }
}
3.带返回值的线程,实现Callable<返回值类型>
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask; public class ThreadDemo implements Callable<String> { public static void main(String[] args) throws ExecutionException, InterruptedException {
ThreadDemo threadDemo = new ThreadDemo();
//将线程任务放入FutureTask中
FutureTask<String> task = new FutureTask<>(threadDemo);
//将task放入Thread类中
Thread thread = new Thread(task);
//开始线程任务
thread.start();
//获得执行的结构
String str = task.get();
System.out.println(str); } /**
* 线程任务的方法,声明Callable接口重写的线程任务方法
*
* @return
* @throws Exception
*/
@Override
public String call() throws Exception {
return "这是一个带返回值的线程";
}
}
二、线程池的创建
java中为我们提供了四种创建线程池的方式:
1.newCachedThreadPool:一个可缓存的线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。
public class ThreadDemo extends Thread { //用static修饰表示该线程池只创建一次
static ExecutorService CachedExecutor = Executors.newCachedThreadPool(); public static void main(String[] args) {
//创建线程实例
ThreadDemo threadDemo = new ThreadDemo();
//将线程丢进线程池中
CachedExecutor.execute(threadDemo); } @Override
public void run() {
System.out.println("这是一个线程");
}
}
2.newFixedThreadPool:一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。
public class ThreadDemo extends Thread { //用static修饰表示该线程池只创建一次
static ExecutorService fixedExecutor = Executors.newFixedThreadPool(5); public static void main(String[] args) {
//创建线程实例
ThreadDemo threadDemo = new ThreadDemo();
//将线程丢进线程池中
fixedExecutor.execute(threadDemo); } @Override
public void run() {
System.out.println("这是一个线程");
}
}
3.newScheduledThreadPool:这是一个定时器的任务线程池,其中第三个参数TimeUnit类,可以参考https://www.cnblogs.com/zhaoyanjun/p/5486726.html
public class ThreadDemo extends Thread { //用static修饰表示该线程池只创建一次
static ScheduledExecutorService scheduledExecutor = Executors.newScheduledThreadPool(5); public static void main(String[] args) {
//创建线程实例
ThreadDemo threadDemo = new ThreadDemo();
//定时器任务的线程,三个参数意义是:1.线程任务 2.时间的次数 3.时间的粒度
//该方法的意义是每5分钟一次执行线程threadDemo
scheduledExecutor.schedule(threadDemo, 5, TimeUnit.MINUTES); } @Override
public void run() {
System.out.println("这是一个线程");
}
}
4.newSingleThreadExecutor:按顺序来执行线程任务 但是不同于单线程,这个线程池只是只能存在一个线程,这个线程死后另外一个线程会补上。
public class ThreadDemo extends Thread { //用static修饰表示该线程池只创建一次
static ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor(); public static void main(String[] args) {
//创建线程实例
ThreadDemo threadDemo = new ThreadDemo();
//将线程放入线程池
singleThreadExecutor.execute(threadDemo); } @Override
public void run() {
System.out.println("这是一个线程");
}
}
最新文章
- AngularJS指令
- 车销宝无线开单PDA 一款互联网+POS神器 无缝与电脑数据同步 无线POS开单解决方案
- 【原】如何改变表单元素的外观(for Webkit and IE10)
- SVM原理与实践
- SQL联合查询两个表的数据
- Javascript中的delete
- [tp3.2.1]让默认页面: 加载Home模块的Index控制器;而让admin.php默认去加载Admin模块的Adminc控制器.
- 从零开始学ios开发(十三):Table Views(下)Grouped and Indexed Sections
- 快捷设置IE代理小工具
- zTree判断是否为父节点
- js相差天数计算
- 编译Firebird的源码
- C#将DataTable导出Execl、Word、Xml
- SQL 计算两个时间之差 分类: SQL Server 2014-07-04 10:57 119人阅读 评论(0) 收藏
- ThinkPHP - 关联模型 - 多对多
- MongoDB---性能优化---(1)
- 对于Netty的十一个疑问
- 使用CEF(CEFGLUE)作为您的客户端UI(一)
- spring 组件自动装载示例(@ComponentScan,@Component,@Scope)
- 集成 solr6.5.1到 tomcat7(8) 中 (解决java.lang.NoSuchMethodError问题)