阿Jie_社区达人页_阿里云开发者社区

头歌Educoder——Java高级特性 - JDBC（下）

第1关：指定类型JDBC封装任务描述本关任务：按照要求封装一个JDBC工具类。相关知识为了完成本关任务，你需要掌握JDBC的基本使用，可参考上一个实训内容 Java高级特性 - JDBC（上）。本章节将针对已知数据结构的某张表进行JDBC的封装。连接数据库在增删改查的过程中，我们都离不开数据库的连接，因此我们可以将其操作封装成一个方法，方法无需参数，将连接对象作为返回值。在方法中完成驱动加载和数据库连接即可使用：private static Connection getConnection() { //1.加载驱动 //2.连接数据库 Connection conn=null; //返回连接对象 return conn; }封装完后我们就可直接在增删改查中直接使用该方法了。关闭数据库连接同样每次连接完数据库我们都需要对相应资源进行释放，我们也将其封装为一个方法，方法参数为经常被使用到的对象，这些对象通常是ResultSet, Statement和Connection，因此我们的关闭连接方法如下：public static void close(ResultSet rs,PreparedStatement ps,Connection conn){ try { if(rs!=null) rs.close(); if(ps!=null) ps.close(); if(conn!=null) conn.close(); } catch (SQLException e) { e.printStackT\frace(); } }新增数据现我们数据库中已有的一张新闻表news，结构如下：字段名称类型备注约束idint新闻编号主键titlevarchar(60)新闻标题无author_namevarchar(30)作者名称无根据表结构我们创建一个News对象：public class News { private int id; private String title; private String anthor_name; public News(int id, String title, String anthor_name) { super(); this.id = id; this.title = title; this.anthor_name = anthor_name; } public int getId() { return id; } public void setId(int id) { this.id = id; } ......//省略其他属性的get、set方法 }日常生活中我们每天都会看到很多新闻，因此我们需要往数据库中不断新增最新新闻，下面我们一起来对新增方法进行封装：封装前我们先对方法进行构思，该方法需传递一个News对象，无需返回值，因此方法的定义和实现思路如下：public void insert(News news) throws SQLException { Connection conn = getConnection();//拿到连接对象 PreparedStatement ps = null; //编写新增sql语句 String sql = ""; try{ ps = conn.prepareStatement(sql); //通过传入的news对象对预编译中 ? 进行赋值 ps.setXXX(1,news.getXXX()); //执行新增sql语句 ps.executeUpdate(); }catch(SQLException e){ e.printStackT\frace(); }finally{ //关闭连接 close(null, ps, conn); } }编程要求在右侧编辑器补充代码，完成数据库连接、删除、更新以及查找方法。其中删除方法是通过用户传入新闻id来进行删除。注意：连接数据库名为mysql_db，数据库用户为root，密码为123123。测试说明平台会对你编写的代码进行测试：测试输入：无预期输出：News [id=1, title=岳云鹏的18岁，贾玲的18岁，沈腾的18岁，网友：不是来搞笑的？, anthor_name=光明网]说明：测试文件中会向news表中插入二条新闻数据，以便对你编写的方法进行检测，数据如下：idtitleauthor_name1岳云鹏的18岁，贾玲的18岁，沈腾的18岁，网友：不是来搞笑的？小明2假设飞行器每秒跑1光年，能飞到宇宙边缘吗？科学家说出答案探索宇宙奥妙开始你的任务吧，祝你成功！实现代码【JDBCUtils.java】package step1; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; import test.News; public class JDBCUtils { /** * 连接数据库 */ private static Connection getConnection() { Connection conn = null; /********** Begin **********/ String url = "jdbc:mysql://localhost:3306/mysql_db"; try { Class.forName("com.mysql.jdbc.Driver"); conn = DriverManager.getConnection(url, "root", "123123"); } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); } /********** End **********/ return conn; } /** * 更新数据方法 * * @param news * @throws SQLException */ public void update(News news) throws SQLException { Connection conn = getConnection(); PreparedStatement ps = null; /********** Begin **********/ String sql = "update news set title = ? ,author_name = ? where id = ? "; try { ps = conn.prepareStatement(sql); ps.setObject(1, news.getTitle()); ps.setObject(2, news.getAuthor_name()); ps.setObject(3, news.getId()); ps.execute(); } catch (SQLException e) { e.printStackTrace(); throw new SQLException("更新数据失败"); } finally { close(null, ps, conn); } /********** End **********/ } /** * 查询所有数据 * * @return * @throws SQLException */ public List<News> findAll() throws SQLException { Connection conn = getConnection(); PreparedStatement ps = null; ResultSet rs = null; News news = null; List<News> newsList = new ArrayList<News>(); /********** Begin **********/ String sql = "select * from news"; try { ps = conn.prepareStatement(sql); rs = ps.executeQuery(); while (rs.next()) { news = new News(rs.getInt(1), rs.getString(2), rs.getString(3)); newsList.add(news); } } catch (SQLException e) { e.printStackTrace(); throw new SQLException("查询所有数据失败"); } finally { close(rs, ps, conn); } /********** End **********/ return newsList; } /** * 删除方法 * * @param id * @throws SQLException */ public void delete(int id) throws SQLException { Connection conn = getConnection(); PreparedStatement ps = null; /********** Begin **********/ String sql = "delete from news where id=?"; try { ps = conn.prepareStatement(sql); ps.setObject(1, id); ps.execute(); } catch (SQLException e) { e.printStackTrace(); throw new SQLException(" 删除数据失败"); } finally { close(null, ps, conn); } /********** End **********/ } /** * 增加对象 * * @param news * @throws SQLException */ public void insert(News news) throws SQLException { Connection conn = getConnection(); PreparedStatement ps = null; String sql = "insert into news(id,title,author_name)values(?,?,?)"; try { ps = conn.prepareStatement(sql); ps.setInt(1, news.getId()); ps.setString(2, news.getTitle()); ps.setString(3, news.getAuthor_name()); ps.executeUpdate(); } catch (SQLException e) { e.printStackTrace(); throw new SQLException("添加数据失败"); } finally { close(null, ps, conn); } } /** * 根据id查询对象 * * @param id * @return * @throws SQLException */ public News findById(int id) throws SQLException { Connection conn = getConnection(); PreparedStatement ps = null; ResultSet rs = null; News news = null; String sql = "select * from news where id=?"; try { ps = conn.prepareStatement(sql); ps.setInt(1, id); rs = ps.executeQuery(); if (rs.next()) { news = new News(); news.setId(id); news.setTitle(rs.getString(2)); news.setAuthor_name(rs.getString(3)); } } catch (SQLException e) { e.printStackTrace(); throw new SQLException("根据ID查询数据失败"); } finally { close(rs, ps, conn); } return news; } /** * 关闭数据库连接 * * @param rs * @param ps * @param conn */ public static void close(ResultSet rs, PreparedStatement ps, Connection conn) { try { if (rs != null) rs.close(); if (ps != null) ps.close(); if (conn != null) conn.close(); } catch (SQLException e) { e.printStackTrace(); } } }【News.java】package test; public class News { private int id; private String title; private String author_name; public News() { super(); } public News(int id, String title, String anthor_name) { super(); this.id = id; this.title = title; this.author_name = anthor_name; } public int getId() { return id; } public void setId(int id) { this.id = id; } public String getTitle() { return title; } public void setTitle(String title) { this.title = title; } public String getAuthor_name() { return author_name; } public void setAuthor_name(String author_name) { this.author_name = author_name; } @Override public String toString() { return "News [id=" + id + ", title=" + title + ", author_name=" + author_name + "]"; } }【Test1.java】package test; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Statement; import java.util.List; import step1.JDBCUtils; public class Test1 { public static void main(String[] args) throws SQLException { createTable(); JDBCUtils jUtils = new JDBCUtils(); News news1 = new News(1, "岳云鹏的18岁，贾玲的18岁，沈腾的18岁，网友：不是来搞笑的？", "小明"); News news2 = new News(2, "假设飞行器每秒跑1光年，能飞到宇宙边缘吗？科学家说出答案", "探索宇宙奥秘"); jUtils.insert(news1); jUtils.insert(news2); // 修改数据 news1.setAuthor_name("光明网"); jUtils.update(news1); // 删除数据 jUtils.delete(2); // 获取表中数据 List<News> findAll = jUtils.findAll(); for (int i = 0; i < findAll.size(); i++) { System.out.println(findAll.get(i)); } // 检测update方法 News findById = jUtils.findById(1); if (!findById.toString().equals(news1.toString())) { System.out.println("数据修改失败,请检查update方法"); System.out.println("查询id为1的结果：" + findById); } // 检查delete方法 News findById2 = jUtils.findById(2); if (findById2 != null) { System.out.println("数据删除失败,请检查delete方法"); System.out.println("查询id为2的结果：" + findById2); } } public static void createTable() { try { Class.forName("com.mysql.jdbc.Driver"); } catch (ClassNotFoundException e) { e.printStackTrace(); } Connection conn = null; Statement statement = null; String url = "jdbc:mysql://localhost:3306/"; try { conn = DriverManager.getConnection(url, "root", "123123"); statement = conn.createStatement(); statement.executeUpdate("drop database if exists mysql_db"); statement.executeUpdate("create database mysql_db"); statement.executeUpdate("use mysql_db"); String sql = "create table news(" + "id int primary key, " + "title varchar(60), " + "author_name varchar(30)" + ")"; statement.executeUpdate(sql); } catch (SQLException e) { e.printStackTrace(); } finally { try { if (statement != null) statement.close(); if (conn != null) conn.close(); } catch (SQLException e) { e.printStackTrace(); } } } }第2关：泛型JDBC封装任务描述本关任务：封装一个泛型类的JDBC工具类。相关知识上一章节中我们对具体类（News）进行JDBC的封装，但是在一个项目中，数据库中的表远不止一个，难道我们需要对每一张表都进行封装吗？显然是不妥的，因此我们可以将JDBC工具类封装为一个泛型的。在学习了反射（ JAVA的重要机制——反射Reflection ）之后,我们都知道反射机制的强大，利用反射可以获取到类的结构信息，动态调用属性和方法等等。因此，本章节我们采用反射对JDBC的增删改查进行泛型的封装。为了完成本关任务，你需要掌握：反射的常用方法。反射的常用方法获取Class的实例的三种方法Class class=类名.class; Class class=Class.forName("全类名"); Class class=对象.getClass();获取对象的类名String className=class.getName();//获取结果为全类名 String className=class.getSimpleName();//获取简单类名获取FieldField field=class.getField("属性名");//通过属性名获取public的属性 Field[] fields=class.getFields();//获取所有用public修饰的属性 Field field=class.getDeclaredField("属性名")；//获取的属性包括public和private Field[] field = c.getDeclaredFields();//获取所有属性包括public和private获取Field的信息String name=field.getName();//获取属性名 Class<?> type=filed.getType();//获取属性类型 Object value=field.get(obj);//获取obj对象field属性的值 field.set(obj,value);//设置obj对象的field属性的值设置private修饰的属性为可访问field.setAccessible(true);//默认为false只能对public修饰的操作，设置为true可对private修饰的操作更新数据的泛型封装分析及实现我们可以从sql语句来进行分析，更新数据的sql，大家都不陌生：update 表名 set column2=value2,columen3=value3 where column1=value1;观察sql语句我们可以将该方法设计为让用户传入一个Object对象，然后利用反射获取对象中的所有属性对其进行修改，具体实现如下（注意Object对象属性名称要求和数据库中表结构字段名以及类型一致）：public static void update(Object obj) { Connection conn = getConnection();//获取连接对象 PreparedStatement ps = null; Class<?> c = obj.getClass();//获取obj的Class StringBuffer sb = new StringBuffer("update "+ c.getSimpleName() +" set ");//利用StringBuffer进行修改SQL语句的构造 Field[] field = c.getDeclaredFields();//通过反射获取对象的属性数组 for(int i = 1; i < field.length; i++) { if(i != field.length-1) { //判断是否为最后一个属性，若不是则后增加逗号 sb.append(field[i].getName()).append("=?,"); }else { //若为最后一个属性则添加 where sb.append(field[i].getName()).append("=? where "); } } //默认第一个属性为主键，切更改时通过第一个属性进行更改 sb.append(field[0].getName() + "=?"); try { ps = conn.prepareStatement(sb.toString()); for(int i = 1; i < field.length; i++) { field[i].setAccessible(true);//设置可以访问私有属性 ps.setObject(i, field[i].get(obj));//对预编译的SQL语句中的 ? 进行赋值 } field[0].setAccessible(true); ps.setObject(field.length, field[0].get(obj)); ps.execute();//执行sql语句 } catch (Exception e) { e.printStackT\frace(); }finally { close(null,ps,conn);//关闭连接数据 } }编程要求根据更新数据的示例，在右侧编辑器补充代码，完成增加数据、删除数据、查询表中所有数据三个方法。测试说明测试输入：无预期输出：Student [id=2, name=李四, sex=男, age=20]News [id=1, title=岳云鹏的18岁，贾玲的18岁，沈腾的18岁，网友：不是来搞笑的？, author_name=光明网]News [id=2, title=假设飞行器每秒跑1光年，能飞到宇宙边缘吗？科学家说出答案, author_name=探索宇宙奥秘]平台将会根据已有的Student表和News表来调用你所编写的方法，进行数据的增删改查，分别为二张表中插入二条数据载进行修改News 表中一条数据，删除Student表中一条数据，插入数据如下：Student表idnamesexage1张三男182李四女20News表idtitleauthor_name1岳云鹏的18岁，贾玲的18岁，沈腾的18岁，网友：不是来搞笑的？光明网2假设飞行器每秒跑1光年，能飞到宇宙边缘吗？科学家说出答案小明注意：本章实训封装的JDBC工具类只做参考，你也可根据自己的实际需求进行封装属于自己的工具类。开始你的任务吧，祝你成功！实现代码【JDBCUtils.java】package step2; import java.lang.reflect.Field; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; public class JDBCUtils { private static Connection getConnection() { try { Class.forName("com.mysql.jdbc.Driver"); } catch (ClassNotFoundException e) { e.printStackTrace(); } String url = "jdbc:mysql://localhost:3306/mysql_db"; Connection conn = null; try { conn = DriverManager.getConnection(url, "root", "123123"); } catch (SQLException e) { e.printStackTrace(); } return conn; } /** * 类名对应表，属性对应字段 * * @param obj 传入的对象 * @return */ public void insert(Object obj) { Connection conn = getConnection(); // 连接数据库 PreparedStatement ps = null; /********** Begin **********/ try { String sql = "insert into "; String sql2 = ") values("; // 获取类名当表名 String simpleName = obj.getClass().getSimpleName(); sql += simpleName + "("; // 获取所有属性 Field[] declaredFields = obj.getClass().getDeclaredFields(); // 拼接sql语句 for (int i = 0; i < declaredFields.length; i++) { sql += declaredFields[i].getName(); sql2 += "?"; if (i + 1 != declaredFields.length) { sql += ","; sql2 += ","; } else { sql2 += ")"; } } sql += sql2; ps = conn.prepareStatement(sql); // 填充占位符 for (int i = 0; i < declaredFields.length; i++) { declaredFields[i].setAccessible(true); Object object = null; try { object = declaredFields[i].get(obj); } catch (Exception e) { e.printStackTrace(); } ps.setObject(i + 1, object); } ps.execute(); } /********** End **********/ catch (SQLException e) { e.printStackTrace(); } finally { close(null, ps, conn); } } /** * 通过对象的Class获取对应表中的所有记录 * * @param c * @return */ public <T> List<T> selectAll(Class<T> c) { Connection conn = getConnection(); List<T> list = new ArrayList<T>(); PreparedStatement ps = null; ResultSet rs = null; /********** Begin **********/ try { // 获取类名当作表名 String simpleName = c.getSimpleName(); // sql查询语句 String sql = "select * from " + simpleName; ps = conn.prepareStatement(sql); // 获取结果集 rs = ps.executeQuery(); // 获取所有属性，对应结果集的所有列 Field[] fields = c.getDeclaredFields(); while (rs.next()) { // 创建对象 T t = c.newInstance(); // 给对象对应的属性赋值 for (Field field : fields) { field.setAccessible(true); field.set(t, rs.getObject(field.getName())); } // 对象添加到集合 list.add(t); } } /********** End **********/ catch (Exception e) { e.printStackTrace(); } finally { close(rs, ps, conn); } return list; } /** * 通过主键(默认第一个属性)删除对象 * * @param obj * @return */ public void delete(Object obj) { Connection conn = getConnection(); PreparedStatement ps = null; /********** Begin **********/ try { // 获取类名当作表明 String simpleName = obj.getClass().getSimpleName(); // 获取第一个属性的信息 Field[] declaredFields = obj.getClass().getDeclaredFields(); declaredFields[0].setAccessible(true); String name = declaredFields[0].getName(); // sql删除语句 String sql = "delete from " + simpleName + " where " + name + "=?"; // 填充占位符 ps = conn.prepareStatement(sql); ps.setObject(1, declaredFields[0].get(obj)); ps.execute(); } /********** End **********/ catch (Exception e) { e.printStackTrace(); } finally { close(null, ps, conn); } } /** * 模拟jdbc的更新操作，默认第一个属性为主键 * * @param obj * @return */ public void update(Object obj) { Class<?> c = obj.getClass();// 获取obj的Class StringBuffer sb = new StringBuffer("update " + c.getSimpleName() + " set ");// 利用StringBuffer进行修改SQL语句的构造 Field[] field = c.getDeclaredFields();// 通过反射获取对象的属性数组 for (int i = 1; i < field.length; i++) { if (i != field.length - 1) { // 判断是否为最后一个属性，若不是则后增加逗号 sb.append(field[i].getName()).append("=?,"); } else { // 若为最后一个属性则添加 where sb.append(field[i].getName()).append("=? where "); } } // 默认第一个属性为主键，切更改时通过第一个属性进行更改 sb.append(field[0].getName() + "=?"); String sql = sb.toString() + ";"; Connection conn = getConnection();// 获取连接对象 PreparedStatement ps = null; try { ps = conn.prepareStatement(sql); for (int i = 1; i < field.length; i++) { field[i].setAccessible(true);// 设置可以访问私有属性 ps.setObject(i, field[i].get(obj));// 对预编译的SQL语句中的 ? 进行赋值 } field[0].setAccessible(true); ps.setObject(field.length, field[0].get(obj)); ps.execute();// 执行sql语句 } catch (Exception e) { e.printStackTrace(); } finally { close(null, ps, conn);// 关闭连接数据 } } public static void close(ResultSet rs, PreparedStatement ps, Connection conn) { try { if (rs != null) rs.close(); if (ps != null) ps.close(); if (conn != null) conn.close(); } catch (SQLException e) { e.printStackTrace(); } } public <T> Object selectById(Class<T> c, int id) { String sql = "select * from " + c.getSimpleName() + " where id=" + id; Field[] field = c.getDeclaredFields(); Connection conn = getConnection(); PreparedStatement ps = null; ResultSet rs = null; Object obj = null; try { ps = conn.prepareStatement(sql); rs = ps.executeQuery(); obj = c.newInstance(); while (rs.next()) { for (int i = 0; i < field.length; i++) { field[i].setAccessible(true); field[i].set(obj, rs.getObject(field[i].getName())); } } } catch (Exception e) { e.printStackTrace(); } finally { close(rs, ps, conn); } return obj; } }【News.java】package test; public class News { private int id; private String title; private String author_name; public News() { super(); } public News(int id, String title, String anthor_name) { super(); this.id = id; this.title = title; this.author_name = anthor_name; } public int getId() { return id; } public void setId(int id) { this.id = id; } public String getTitle() { return title; } public void setTitle(String title) { this.title = title; } public String getAuthor_name() { return author_name; } public void setAuthor_name(String author_name) { this.author_name = author_name; } @Override public String toString() { return "News [id=" + id + ", title=" + title + ", author_name=" + author_name + "]"; } }【Test2.java】package test; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Statement; import java.util.List; import step2.JDBCUtils; public class Test2 { static JDBCUtils jUtils = new JDBCUtils(); public static void main(String[] args) { createTable(); Student student1 = new Student(1, "张三", "男", 18); Student student2 = new Student(2, "李四", "女", 20); News news1 = new News(1, "岳云鹏的18岁，贾玲的18岁，沈腾的18岁，网友：不是来搞笑的？", "光明网"); News news2 = new News(2, "假设飞行器每秒跑1光年，能飞到宇宙边缘吗？科学家说出答案", "小明"); jUtils.insert(student1); jUtils.insert(student2); jUtils.insert(news1); jUtils.insert(news2); isTrue(student1, student2, news1, news2, "新增"); news2.setAuthor_name("探索宇宙奥秘"); jUtils.update(news2); student2.setSex("男"); jUtils.update(student2); isTrue(student1, student2, news1, news2, "更新"); jUtils.delete(student1); List<Student> studentList1 = jUtils.selectAll(Student.class); if (studentList1.size() != 0) { if (studentList1.size() != 1) { System.out.println("数据删除失败,请检查delete方法。" + student1.toString() + "未被删除成功"); } } else { System.out.println("请完成查询方法"); } List<Student> studentList = jUtils.selectAll(Student.class); for (int i = 0; i < studentList.size(); i++) { System.out.println(studentList.get(i)); } List<News> newsList = jUtils.selectAll(News.class); for (int i = 0; i < newsList.size(); i++) { System.out.println(newsList.get(i)); } } public static void createTable() { try { Class.forName("com.mysql.jdbc.Driver"); } catch (ClassNotFoundException e) { e.printStackTrace(); } Connection conn = null; Statement statement = null; String url = "jdbc:mysql://localhost:3306/"; try { conn = DriverManager.getConnection(url, "root", "123123"); statement = conn.createStatement(); statement.executeUpdate("drop database if exists mysql_db"); statement.executeUpdate("create database mysql_db"); statement.executeUpdate("use mysql_db"); String sql = "create table News(" + "id int primary key, " + "title varchar(60), " + "author_name varchar(30)" + ")"; statement.executeUpdate(sql); String sql2 = "create table Student(" + "id int primary key, " + "name varchar(20), " + "sex varchar(4)," + "age int" + ")"; statement.executeUpdate(sql2); } catch (SQLException e) { e.printStackTrace(); } finally { try { if (statement != null) statement.close(); if (conn != null) conn.close(); } catch (SQLException e) { e.printStackTrace(); } } } public static void isTrue(Student student1, Student student2, News news1, News news2, String type) { Student s1 = (Student) jUtils.selectById(Student.class, 1); Student s2 = (Student) jUtils.selectById(Student.class, 2); News n1 = (News) jUtils.selectById(News.class, 1); News n2 = (News) jUtils.selectById(News.class, 2); if (!student1.toString().equals(s1.toString()) || !student2.toString().equals(s2.toString()) || !news1.toString().equals(n1.toString()) || !news2.toString().equals(n2.toString())) { System.out.println("请按要求完成" + type + "方法"); } } }

Educoder头歌—Java多线程基础常用函数

第1关：线程的状态与调度任务描述本关任务：学习本关知识完成选择题。相关知识为了完成本关你需要掌握：1.线程的状态与调度；2.线程执行的优先级。线程的状态与调度如果看懂下图，你对线程的了解就会更上一层楼。当我们使用new关键字新建一个线程，这个时候线程就进入了新建状态（New），也就是图中未启动状态；调用start方法启动线程，这个时候就进入了可运行状态，也就是就绪状态（Runnable）；就绪状态获取了CPU资源，开始执行run方法，就进入了运行状态（Running）；阻塞状态（Blocked）：阻塞状态是线程因为某种原因放弃CPU使用权，暂时停止运行。直到线程进入就绪状态，才有机会转到运行状态。阻塞的情况分三种；等待阻塞：运行的线程执行wait()方法，JVM会把该线程放入等待池中。(wait会释放持有的锁)；同步阻塞：运行的线程在获取对象的同步锁时，若该同步锁被别的线程占用，则JVM会把该线程放入锁池中；其他阻塞：运行的线程执行sleep()或join()方法，或者发出了I/O请求时，JVM会把该线程置为阻塞状态。当sleep()状态超时、join()等待线程终止或者超时、或者I/O处理完毕时，线程重新转入就绪状态。（注意,sleep是不会释放持有的锁）；死亡状态（Dead）：线程执行完了或者因异常退出了run()方法，该线程结束生命周期。线程优先级我们知道，多个线程的执行是随机的，在一个时段执行哪个线程是看哪一个线程在此时拥有CPU的执行权限。在Java中线程有优先级，优先级高的线程会获得较多的运行机会。Java线程的优先级用整数表示，取值范围是1~10，Thread类有以下三个静态常量：static int MAX_PRIORITY 线程可以具有的最高优先级，取值为10。 static int MIN_PRIORITY 线程可以具有的最低优先级，取值为1。 static int NORM_PRIORITY 分配给线程的默认优先级，取值为5。如果要设置和获取线程的优先级，可以使用Thread类的setPriority()和getPriority()方法。每个线程都有默认的优先级。主线程的默认优先级为Thread.NORM_PRIORITY。线程的优先级有继承关系，比如A线程中创建了B线程，那么B将和A具有相同的优先级。JVM提供了10个线程优先级，但与常见的操作系统都不能很好的映射。如果希望程序能移植到各个操作系统中，应该仅仅使用Thread类有以下三个静态常量作为优先级，这样能保证同样的优先级采用了同样的调度方式。关于线程调度与优先级你还需要了解：线程睡眠：Thread.sleep(long millis)方法，使线程转到阻塞状态。millis参数设定睡眠的时间，以毫秒为单位。当睡眠结束后，就转为就绪（Runnable）状态。sleep()平台移植性好。线程等待：Object类中的wait()方法，导致当前的线程等待，直到其他线程调用此对象的 notify() 方法或 notifyAll() 唤醒方法。这个两个唤醒方法也是Object类中的方法，行为等价于调用 wait(0) 一样。线程让步：Thread.yield() 方法，暂停当前正在执行的线程对象，把执行机会让给相同或者更高优先级的线程。线程加入：join()方法，等待其他线程终止。在当前线程中调用另一个线程的join()方法，则当前线程转入阻塞状态，直到另一个进程运行结束，当前线程再由阻塞转为就绪状态。线程唤醒：Object类中的notify()方法，唤醒在此对象监视器上等待的单个线程。如果所有线程都在此对象上等待，则会选择唤醒其中一个线程。选择是任意性的，并在对实现做出决定时发生。线程通过调用其中一个 wait 方法，在对象的监视器上等待。直到当前的线程放弃此对象上的锁定，才能继续执行被唤醒的线程。被唤醒的线程将以常规方式与在该对象上主动同步的其他所有线程进行竞争；例如，唤醒的线程在作为锁定此对象的下一个线程方面没有可靠的特权或劣势。类似的方法还有一个notifyAll()，唤醒在此对象监视器上等待的所有线程。编程要求略 ####测试说明略题1、有三种原因可以导致线程不能运行，它们是（ ABC ）A、等待B、阻塞C、休眠D、挂起及由于I/O操作而阻塞2、Java语言中提供了一个（ D ）线程，自动回收动态分配的内存。A、异步B、消费者C、守护D、垃圾收集3、当（ A ）方法终止时，能使线程进入死亡状态A、runB、setPriorityC、yieldD、sleep4、用（ B ）方法可以改变线程的优先级。A、runB、setPriorityC、yieldD、sleep5、线程通过（ D ）方法可以休眠一段时间，然后恢复运行A、runB、setPriorityC、yieldD、sleep6、下列关于线程的说法正确的是（ ABD ）A、如果线程死亡，它便不能运行B、在Java中，高优先级的可运行线程会抢占低优先级线程C、线程可以用yield方法使低优先级的线程运行D、一个线程可以调用yield方法使其他线程有机会运行第2关：常用函数（一）任务描述本关任务：获取子线程执行的结果并输出。相关知识2本关你需要掌握sleep与join函数的用法。sleep()函数sleep(long millis): 在指定的毫秒数内让当前正在执行的线程休眠（暂停执行）。使用方式很简单在线程的内部使用Thread.sleep(millis)即可。sleep()使当前线程进入停滞状态（阻塞当前线程），让出CPU的使用，目的是不让当前线程独自霸占该进程所获的CPU资源，以留一定时间给其他线程执行的机会；在sleep()休眠时间期满后，该线程不一定会立即执行，这是因为其它线程可能正在运行而且没有被调度为放弃执行，除非此线程具有更高的优先级。join()函数join函数的定义是指：等待线程终止。我们在运行线程的时候可能会遇到，在主线程中运行子线程，主线程需要获取子线程最终执行结果的情况。但是有很多时候子线程进行了很多耗时的操作，主线程往往先于子线程结束，这个时候主线程就获取不到子线程的最终执行结果了。使用join函数，可以解决这一问题。我们通过两个示例来理解：不使用join函数的版本：class MyThread extends Thread { private String name; public MyThread(String name) { this.name = name; } public void run() { System.out.println("子线程开始运行"); for (int i = 0; i < 5; i++) { System.out.println("子线程" + name + "运行" + i); try { Thread.sleep(30); } catch (InterruptedException e) { e.printStackT\frace(); } } System.out.println("子线程结束"); } } public class Test { public static void main(String[] args) { Thread t = new MyThread("子线程A"); t.start(); for (int i = 0; i < 5; i++) { System.out.println("主线程执行" + i); } System.out.println("主线程结束"); } }输出结果（每次都不一样）：主线程执行0主线程执行1主线程执行2主线程执行3主线程执行4主线程结束子线程开始运行子线程子线程A运行0子线程子线程A运行1子线程子线程A运行2子线程子线程A运行3子线程子线程A运行4子线程结束可以发现每次运行，主线程都是先于子线程结束的。使用join函数：package step1; class MyThread extends Thread { private String name; public MyThread(String name) { this.name = name; } public void run() { System.out.println("子线程开始运行"); for (int i = 0; i < 5; i++) { System.out.println("子线程" + name + "运行" + i); try { Thread.sleep(30); } catch (InterruptedException e) { e.printStackT\frace(); } } System.out.println("子线程结束"); } } public class Test { public static void main(String[] args) { Thread t = new MyThread("子线程A"); t.start(); for (int i = 0; i < 5; i++) { System.out.println("主线程执行" + i); } try { t.join(); } catch (Exception e) { e.printStackT\frace(); } System.out.println("主线程结束"); } }输出结果：主线程执行1主线程执行2主线程执行3子线程开始运行主线程执行4子线程子线程A运行0子线程子线程A运行1子线程子线程A运行2子线程子线程A运行3子线程子线程A运行4子线程结束主线程结束可以发现无论运行多少次，主线程都会等待子线程结束之后在结束。编程要求请仔细阅读右侧代码，根据方法内的提示，在Begin - End区域内进行代码补充，具体任务如下：创建自定义线程，实现求第num项斐波那契数列的值num从0开始，并且在main函数中获取子线程最终计算的结果。测试说明补充完代码后，点击测评，平台会对你编写的代码进行测试，当你的结果与预期输出一致时，即为通过。输入：5输出：子线程计算结果为：5输入：8输出：子线程计算结果为：21输入：10输出：子线程计算结果为：55开始你的任务吧，祝你成功！代码示例package step2; import java.util.Scanner; public class Task { public static void main(String[] args) { Scanner sc = new Scanner(System.in); int num = sc.nextInt(); // 请在此添加实现代码 /********** Begin **********/ MyThread mt = new MyThread(num); mt.start(); try { mt.join(); } catch (InterruptedException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } /********** End **********/ } } //请在此添加实现代码 /********** Begin **********/ class MyThread extends Thread { int num; public MyThread(int num) { this.num = num; } @Override public void run() { // TODO 自动生成的方法存根 System.out.println("子线程计算结果为：" + num(num)); } public int num(int n) { if (n < 3) { return 1; } else return num(n - 1) + num(n - 2); } } /********** End **********/第3关：常用函数（二）任务描述本关任务：使用三个线程交替打印5次EDU。相关知识为了完成本关任务你需要掌握：1.yield函数的用法；2.wait函数的用法；3.其他常用函数的使用。yield 函数yield函数可以理解为“让步”，它的作用是：暂停当前正在执行的线程对象，并执行其他线程。yield()应该做的是让当前运行线程回到可运行状态，以允许具有相同优先级的其他线程获得运行机会。因此，使用yield()的目的是让相同优先级的线程之间能适当的轮转执行。但是，实际中无法保证yield()达到让步目的，因为让步的线程还有可能被线程调度程序再次选中。示例：public class Task { public static void main(String[] args) { System.out.println(Thread.currentThread().getName()+"主线程运行开始!"); MyThread mTh1=new MyThread("A"); MyThread mTh2=new MyThread("B"); mTh1.start(); mTh2.start(); System.out.println(Thread.currentThread().getName()+ "主线程运行结束!"); } } class MyThread extends Thread { private String name; public MyThread(String name) { this.name = name; } public void run() { for (int i = 0; i < 50; i++) { System.out.println(name + "线程" + "执行" + i); if(i == 10){ this.yield(); } } } }运行结果有两种情况：第一种情况：A（线程）当执行到10时会让掉CPU时间，这时B（线程）抢到CPU时间并执行。第二种情况：B（线程）当执行到10时会让掉CPU时间，这时A（线程）抢到CPU时间并执行。我们还可以考虑在其中加入setPriority函数改变线程优先级从而改变线程的执行顺序。wait 函数要弄明白wait函数我们首先需要了解线程锁的概念。线程锁：其实就像我们日常生活中的锁，如果一个房子上了锁，别人就进不去，在Java中也类似，如果一段代码取得了锁，那么其他地方就不能运行这段代码，只能等待锁的释放。这里我们会涉及到两个函数，1.wait()，2.notify()。这两个函数都是Object类自带的函数。在下面的例子中我们会使用synchronized(Obj)来实现线程同步，同步的概念后面会讲到，这里不理解没关系，不影响对于wait函数的理解。从功能上来说：wait()就是说线程在获取对象锁后，主动释放对象锁，同时本线程休眠。直到有其它线程调用对象的notify()唤醒该线程，才能继续获取对象锁，并继续执行；相应的notify()就是对对象锁的唤醒操作。但有一点需要注意的是notify()调用后，并不是马上就释放对象锁的，而是在相应的synchronized(){}语句块执行结束，自动释放锁后，JVM会在wait()对象锁的线程中随机选取一线程，赋予其对象锁，唤醒线程，继续执行。这样就提供了在线程间同步、唤醒的操作。Thread.sleep()与Object.wait()二者都可以暂停当前线程，释放CPU控制权，主要的区别在于Object.wait()在释放CPU同时，释放了对象锁的控制。纸上得来终觉浅，欲知此事须躬行，我们还是通过实例来学习这些函数的用法。问题：建立两个线程，A线程打印5次A，B线程打印5次B，要求线程同时运行，交替打印5次AB。这个问题用Object的wait()，notify()就可以很方便的解决。代码如下：public class MyThread implements Runnable { private String name; private Object prev; private Object self; private MyThread(String name, Object prev, Object self) { this.name = name; this.prev = prev; this.self = self; } public void run() { int count = 5; while (count > 0) { synchronized (prev) { synchronized (self) { System.out.print(name); count--; self.notify(); } try { prev.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } } System.exit(0);//退出jvm } public static void main(String[] args) throws Exception { Object a = new Object(); Object b = new Object(); MyThread ta = new MyThread("A", b, a); MyThread tb = new MyThread("B", a, b); new Thread(ta).start(); Thread.sleep(100); //确保按顺序A、B执行 new Thread(tb).start(); Thread.sleep(100); } }运行程序，结果为：ABABABABAB线程常用函数总结下表列出的是线程类常用的函数：函数描述public void start()使该线程开始执行；Java 虚拟机调用该线程的 run 方法。public void run()如果该线程是使用独立的 Runnable 运行对象构造的，则调用该 Runnable 对象的 run 方法；否则，该方法不执行任何操作并返回。public final void setName(String name)改变线程名称，使之与参数 name 相同。public final void setPriority(int priority)更改线程的优先级。public final void setDaemon(boolean on)将该线程标记为守护线程或用户线程。public final void join(long millisec)等待该线程终止的时间最长为 millis 毫秒public void interrupt()中断线程。public final boolean isAlive()测试线程是否处于活动状态。public static void yield()暂停当前正在执行的线程对象，并执行其他线程。public static void sleep(long millisec)在指定的毫秒数内让当前正在执行的线程休眠（暂停执行），此操作受到系统计时器和调度程序精度和准确性的影响。public static boolean holdsLock(Object x)当且仅当当前线程在指定的对象上保持监视器锁时，才返回 true。public static Thread currentThread()返回对当前正在执行的线程对象的引用。public static void dumpStack()将当前线程的堆栈跟踪打印至标准错误流。编程要求请仔细阅读右侧代码，根据方法内的提示，在Begin - End区域内进行代码补充，具体任务如下：建立三个线程，A线程打印5次E，B线程打印5次D，C线程打印5次U，要求线程同时运行，交替打印5次EDU。测试说明补充完代码后，点击测评，平台会对你编写的代码进行测试，当你的结果与预期输出一致时，即为通过。开始你的任务吧，祝你成功！代码示例package step3; public class MyThread implements Runnable { // 请在此添加实现代码 /********** Begin **********/ private String name; private Object prev; private Object self; private MyThread(String name, Object prev, Object self) { this.name = name; this.prev = prev; this.self = self; } public void run() { int count = 5; while (count > 0) { synchronized (prev) { synchronized (self) { System.out.print(name); count--; self.notify(); } try { prev.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } } System.exit(0);// 退出jvm } public static void main(String[] args) throws Exception { Object a = new Object(); Object b = new Object(); Object c = new Object(); MyThread ta = new MyThread("E", c, b); MyThread tb = new MyThread("D", b, a); MyThread tc = new MyThread("U", a, c); new Thread(ta).start(); Thread.sleep(100); // 确保按顺序A、B执行 new Thread(tb).start(); Thread.sleep(100); new Thread(tc).start(); } /********** End **********/ }输出：EDUEDUEDUEDUEDU

阿Jie_社区达人页

SpringBoot 发送邮箱验证码（HTML模板）

传智书城源码

MyBatis-Plus——代码生成器（3.5.1+版本）

PyCharm IDEA 安装【Chinese（Simplified）Language Pack/中文语言包】插件汉化出错

IDEA 报错：org.apache.jasper.JasperException:无法在web.xml或使用此应用程序部署的jar文件中解析绝对uri

头歌Educoder——Java高级特性 - JDBC（下）

头歌Educoder——Java高级特性 - JDBC（上）

利用PicGo Core+阿里云OSS搭建图床

头歌Educoder——Java高级特性 - 多线程练习题

Educoder头歌—Java多线程基础常用函数

头歌Educoder——Java 字符串与集合练习—词频统计(一)

头歌Educoder——大数据Hadoop开发环境搭建（三）

头歌Educoder——大数据Hadoop开发环境搭建（二）

头歌Educoder——大数据Hadoop开发环境搭建（一）

头歌Educoder——Java面向对象 - 文件类(二)

头歌Educoder——Java面向对象 - 文件类(一)

Java使用replaceAll()方法过滤字符串中的html标签

个人社区（博客）项目Romantic——功能模块划分

计算机毕业设计——个人社区（博客）项目Romantic

手把手带你复刻CSDN添加文章标签

jQuery图像查看插件Zoom.js

树莓派4B Ubuntu系统安装Linux宝塔面板

Thymeleaf 截取字符串只留取显示部分

自定义SpringBoot启动图标

树莓派4B使用Docker部署SpringBoot项目——（五）使用花生壳进行公网访问

树莓派4B使用Docker部署SpringBoot项目——（四）Docker部署SpringBoot项目

树莓派4B使用Docker部署SpringBoot项目——（三）使用Docker制作JDK8镜像

SQLyog远程连接Docker的MySQL容器报：错误代码1130

树莓派4B使用Docker部署SpringBoot项目——（二）使用docker安装mysql

树莓派4B使用Docker部署SpringBoot项目——（一）树莓派安装docker

实现公网访问树莓派4B（花生壳内网穿透）

3D打印树莓派4B外壳—内置UPS和统计显示信息

找出未来20年内的剁手日

树莓派安装Ubuntu Server系统

树莓派安装Debian-Pi-Aarch64桌面全功能版

树莓派安装Debian-Pi-Aarch64无桌面增强版系统