[泛型类型参数]的搜索结果

泛型（T） , 在Java编程语言中，泛型是一种提供类型安全的机制，允许程序员在定义类、接口和方法时使用未知的具体类型。这里的\ T\ 是一个占位符，代表一个待指定的具体类型。在文章示例的Example类中，T被用作成员变量data的类型，这意味着当创建Example对象时，可以根据实际需求指定任意类型的数据，编译器会在编译时期确保类型的一致性，从而避免运行时期的ClassCastException错误。 泛型类型参数 , 在Java中，泛型类型参数是指在定义泛型类或方法时使用的未指定类型的占位符。例如，本文中的\ T\ 就是一个泛型类型参数，它表示某种未知的类型，并且在实例化泛型类时可以被替换为具体类型，如Integer、String等。通过这种方式，开发者可以在编译阶段就能捕获到可能出现的类型不匹配问题，提高代码的安全性和可读性。 类型擦除 , 虽然Java的泛型提供了编译时期的类型检查，但在运行时，Java虚拟机（JVM）并不知道泛型的具体类型，这是因为Java采用了类型擦除的概念。也就是说，Java泛型只存在于编译阶段，编译后的字节码中不会包含任何泛型信息，所有的类型参数都会被擦除并替换为它们的上限边界（默认是Object）。例如，在泛型类Example<T>中，无论T是什么类型，在运行时，其成员变量data将被视为Object类型。这种机制使得Java能够在保持向后兼容的同时实现泛型功能。

...Flink对Java泛型类型的识别和处理机制。这篇文章呢，咱们要来个深度挖掘，把这个异常现象背后的小秘密给揪出来，还会配上些实实在在的代码例子，一起唠唠怎么才能真正地防止和搞定这个问题。 二、理解TypeInformationException（≈250字） 在Flink的世界里，TypeInformation扮演着至关重要的角色。它包含了数据类型的所有必要信息，如类型是否可null、是否基本类型、是否有字段以及字段的类型等。对于使用了泛型的数据类型，Flink需要获取到具体的类型参数信息以便正确处理。当Flink无法自动推断出泛型的具体类型时，就会抛出"Missing type information for generic type parameter"的异常。 三、案例分析（≈300字 + 代码示例 ≈ 150字） 假设我们在Flink作业中定义了一个泛型类Event，并尝试将其作为DataStream的元素类型： java public class Event { private T payload; // ... getters and setters } DataStream> stream = env.addSource(new FlinkSource>()); 运行上述代码时，Flink就无法确定T的具体类型，从而引发"TypeInformationException"。因为?通配符表示任何类型，Flink无法从Event推导出确切的TypeInformation。 为了解决这个问题，我们需要显式地提供TypeInformation： java TypeInformation> stringTypeInfo = TypeInformation.of(new TypeHint>() {}); DataStream> stream = env.addSource(new FlinkSource<>(stringTypeInfo)); 四、深入解决方案（≈250字 + 代码示例 ≈ 150字） 另一种更为通用的方法是使用TypeInformation.of()或TypeExtractor.createTypeInfo()方法，结合TypeHint或自定义的TypeInformation子类来明确指定泛型参数的类型： java // 使用TypeHint方式 TypeInformation> integerTypeInfo = TypeInformation.of(new TypeHint>() {}); DataStream> integerStream = env.addSource(new FlinkSource<>(integerTypeInfo)); // 或者使用TypeExtractor方式 TypeInformation> doubleTypeInfo = TypeExtractor.getForClass(Event.class) .forGenericTypes(Double.class); DataStream> doubleStream = env.addSource(new FlinkSource<>(doubleTypeInfo)); 五、思考与总结（≈200字） 面对“Missing type information for generic type parameter”这类异常，我们需要理解其背后的原理：Flink为了确保数据处理的正确性和效率，必须清楚每种数据类型的细节。所以，说到泛型这事儿，开发者们最好积极拥抱Flink的类型系统，明确地提供各类类型信息，别藏着掖着~此外，在设计数据模型时，尽可能避免过度复杂的泛型结构也能降低此类问题的发生概率。记住了啊，编程不只是敲出能跑起来的代码那么简单，更重要的是要深入理解并完全掌握系统的底层运作机制。这样一来，无论遇到什么难题挑战，都能像庖丁解牛那样游刃有余地应对处理。

...本概念及操作方式，但类型转换的深度应用远不止于此。近期，在开发Spring框架5.x版本的应用程序时，开发者们更关注如何安全且高效地运用类型转换来实现灵活的设计模式。 例如，在处理依赖注入（Dependency Injection）时，开发者可能需要将容器管理的父类Bean实例转换为具体的子类实例。Spring框架通过AOP代理和类型检查机制，提供了一种更为智能和安全的转换方式。同时，Java 8及更高版本引入了Optional类以增强类型安全，开发者可以通过Optional提供的map方法进行安全的向下转型，从而避免ClassCastException异常。 深入探究，类型转换还涉及Java运行时的类型信息获取、泛型擦除等复杂问题。在处理集合类如List中存储Cat对象并进行向下转型时，可以借助Java反射API或TypeReference类解决泛型类型擦除带来的不便。 此外，《Effective Java》一书中的Item 53：优先使用继承而非类型参数化来实现“is-a”关系，强调了正确理解并使用类型转换对于设计稳定、易于维护的代码库至关重要。这也提醒我们在实际编程中，不仅要掌握类型转换的技巧，更要遵循面向对象设计原则，合理利用继承与多态特性，确保代码的可读性和扩展性。 总的来说，理解并熟练运用Java中的类型转换不仅是实现功能的基础，也是优化性能、提高代码质量的关键所在。随着技术的发展，诸如Project Valhalla等新特性的引入将进一步丰富Java类型系统，使得类型转换在未来的Java编程中有更多可能性和挑战等待我们去探索。

Java中泛型方法和类是Java中重要的特性，它为Java类型提供了类型参数化类型的完美支撑。Java中的泛型许可程序员编写具有复用性、类型安全性和可读性以及减少代码重复量等优点的代码。 起首，让我们来看看泛型方法。泛型方法是一种将类型类型参数化的方法。所谓类型参数化是指，我们可以在呼叫方法时传递类型参数，在编写方法时使用该参数。以下是泛型方法的语法规则： public <T> void genericMethod(T parameter) { //泛型函数体 } 在上面的语法中，<T>是类型参数，它可以是任何Java符号，在函数体中可以使用，参数T是方法的参数，可以是任何Java类。 接下来，我们来看看泛型类。泛型类是指可以在定义时使用一个或多个类型参数的类。以下是泛型类的语法规则： public class GenericClass<T> { private T memberVar; } 在上面的语法中，<T>是类型参数，在类的定义中被使用，它可以是任何Java符号，类成员memberVar是T类型的。 泛型方法和泛型类的使用可以大大提高程序的可读性和复用性。同时，Java中的泛型还可以确保类型安全性，避免了一些由类型转换错误导致的错误。

高级类型系统：探索Scala中的Existential Types（存在类型） 在Scala的丰富类型系统中，有一种相对复杂但功能强大的特性——Existential Types（存在类型）。本文我们将一起深入探讨这种类型的含义、作用以及实际应用场景，并通过一系列生动的代码示例来帮助大家理解和掌握这一概念。 1. 存在类型的初识 存在类型，直译为“存在的类型”，是一种声明“存在某种特定类型，但我并不关心具体是什么类型”的方式。这就像是我们平时做事，甭管具体的“家伙”是个啥类型，只要它能按照约定的方式工作，或是满足我们设定的条件，我们就能轻松对付。就拿生活中来说吧，你不需要知道手里的遥控器是什么牌子什么型号，只要你明白它是用来控制电视的，按对了按钮就能达到目的，这就是所谓的“只关注实现的接口或满足的条件”，而不是纠结于它的具体身份。 想象一下，你是一个动物园管理员，你知道每种动物都有一个eat的行为，但并不需要确切知道它们是狮子、老虎还是熊猫。在Scala的世界里，这就对应于存在类型的概念。 scala trait Eater { def eat(food: String): Unit } val animal: Eater forSome { type T } = new Animal() { def eat(food: String) = println(s"Animal is eating $food") } 上述代码中，Eater forSome { type T }就是一个存在类型，我们只知道animal实现了Eater特质，而无需关心其具体的类型信息。 2. 存在类型的语法与理解 在Scala中，存在类型的语法形式通常表现为Type forSome { TypeBounds }。这里的TypeBounds是对未知类型的一种约束或定义，可以是特质、类或其他类型参数。 例如： scala val list: List[T] forSome { type T <: AnyRef } = List("Apple", "Banana") list.foreach(println) 在这个例子中，我们声明了一个列表list，它的元素类型T满足AnyRef（所有引用类型的超类）的下界约束，但我们并不知道T具体是什么类型，只知道它可以安全地传递给println函数。 3. 存在类型的实用场景 存在类型在实际编程中主要用于泛型容器的返回和匿名类型表达。特别是在捣鼓API设计的时候，当你想把那些复杂的实现细节藏起来，只亮出真正需要的接口给大伙儿用，这时候类型的作用就凸显出来了，简直不能更实用了。 例如，假设我们有一个工厂方法，它根据配置创建并返回不同类型的数据库连接： scala trait DatabaseConnection { def connect(): Unit def disconnect(): Unit } def createDatabaseConnection(config: Config): DatabaseConnection forSome { type T <: DatabaseConnection } = { // 根据config创建并返回一个具体的DatabaseConnection实现 // ... val connection: T = ... // 假设这里已经创建了某个具体类型的数据库连接 connection } val connection = createDatabaseConnection(myConfig) connection.connect() connection.disconnect() 在这里，使用者只需要知道createDatabaseConnection返回的是某种实现了DatabaseConnection接口的对象，而不必关心具体的实现类。 4. 对存在类型的思考与探讨 存在类型虽然强大，但使用时也需要谨慎。要是老这么使劲儿用，可能会把一些类型信息给整没了，这样一来，编译器就像个近视眼没戴眼镜，查不出代码里所有的类型毛病。这下可好，代码不仅读起来费劲多了，安全性也大打折扣，就像你走在满是坑洼的路上，一不小心就可能摔跟头。同时，对于过于复杂的类型系统，理解和调试也可能变得困难。 总的来说，Scala的存在类型就像是编程世界里的“薛定谔的猫”，它的具体类型取决于运行时的状态，这为我们提供了更加灵活的设计空间，但同时也要求我们具备更深厚的类型系统理解和良好的抽象思维能力。所以在实际动手开发的时候，咱们得看情况灵活应变，像聪明的狐狸一样权衡这个高级特性的优缺点，找准时机恰到好处地用起来。

...序列化为各种Java类型，如基本类型、List、Set、Map以及自定义Java Bean等。在本文的具体情境中，ObjectMapper通过readValue方法将JSON字符串转换成一个Map对象。 TypeReference , 这是Jackson库中的一个泛型类，用于在运行时捕获并保存泛型类型信息。由于Java的类型擦除机制，无法直接获取到参数化类型的Class对象，而TypeReference则提供了一种方式绕过这个问题，在JSON反序列化过程中，能够精确地指定目标类型，从而帮助ObjectMapper准确地将JSON内容转换为具有复杂泛型结构的Java对象，如Map<String, Object>或其他嵌套类型的集合。在文章示例代码中，TypeReference用于指示将JSON字符串转换为Map类型。

...模板类是一种允许创建泛型类的机制，它可以在不指定具体数据类型的情况下定义类的行为。模板类使得同一份代码可以处理多种数据类型，从而提高代码的复用性和灵活性。在文章中，模板类被用来创建链表，使得链表可以存储任意类型的元素。 链表 , 链表是一种常见的数据结构，由一系列节点组成，每个节点包含数据部分和指向下一个节点的指针。链表的特点是插入和删除操作较为简单，无需移动其他元素。在文章中，链表被用来演示模板类的应用，通过模板类实现了一个可以存储任意类型数据的链表。 编译错误 , 编译错误是指在将源代码转换成可执行文件的过程中，编译器发现代码存在不符合语法规范或逻辑错误的情况。在文章中，作者在使用模板类构建链表时遇到了编译错误，主要原因是模板类在使用时需要指定类型参数，而作者在某些地方忘记指定了类型参数，导致编译器无法识别具体的模板实例。

...的元素可以是任意引用类型，若要存储基本类型的数据，则需要使用对应的基本类型包装类。 AbstractList , AbstractList是Java集合框架中的一个抽象类，它是List接口的一个实现骨架，为子类提供了一种方便的方式来实现List接口的部分或全部方法。ArrayList作为AbstractList的子类，通过继承并扩展其实现，简化了自身对List接口方法的实现过程。 泛型（Generics） , 泛型是Java SE 5.0引入的新特性，允许在定义类、接口和方法时声明类型参数。在文章中提到的ArrayList<>，尖括号里的“<>”就是用来指定ArrayList所存储元素的数据类型的占位符，例如ArrayList<String>表示这个ArrayList只能存储字符串对象。通过泛型，可以在编译时期检查类型安全，并且不需要进行强制类型转换，提高了代码的可读性和健壮性。 基本类型包装类 , 在Java中，基本类型如int、boolean、char等不能直接放入集合中，因为集合只能存储对象。为了能够将基本类型存入集合，Java为每种基本类型设计了一个对应的引用类型，这些类型被称为基本类型包装类，例如Integer（对应int）、Boolean（对应boolean）、Character（对应char）等。在文章中提到，当需要将基本类型数据存储到ArrayList这样的集合中时，就需要用到这些基本类型包装类。

...，构造函数是一种特殊类型的成员函数，与类同名且无返回类型。它在创建对象时自动调用，用于初始化对象的数据成员。构造函数可以带有参数，通过传递不同的实参给构造函数，实现对不同对象的个性化初始化。例如，在文章中的例子中，定义了一个带形参的构造函数Box(int h, int w, int len)，当创建一个Box对象时，可以通过该构造函数设置长方体的高、宽和长度。 析构函数 , 析构函数也是C++中一种特殊的成员函数，以符号“~”开头后跟类名，没有返回类型和参数。其主要作用在于对象生命周期结束时，系统自动调用析构函数，执行必要的清理工作，如释放对象占用的内存资源。例如，在文中所示的Student类中，定义了析构函数~Student()，当对象不再使用（如函数结束或delete动态分配的对象）时，会自动调用析构函数，并输出\ Destructor called.\ 来指示析构过程的发生。 类模板 , 类模板是C++中的一种泛型编程机制，允许程序员编写能够处理多种数据类型的类。在编译期间，根据传入的实际类型参数生成具体的类。类模板定义了一种模式，可以根据实际需要实例化为具有特定类型的类。例如，文章给出的【例3.14】声明了一个类模板，可以用来比较并获取两个整数、浮点数或字符之间的大小关系，通过将不同类型作为模板参数传入，系统会自动生成相应的比较类。

...加锁Map集合，其中泛型随意，UUID只是举例。static Map<UUID, UUID> m = Collections.synchronizedMap(new HashMap<UUID, UUID>()); 通过阅读源码发现，上面方法将HashMap变为加锁，也是使用Synchronized，只是锁的内容更细，但并不比HashTable效率高多少 所以衍生除了新的容器ConcurrentHashMap ConcurrentHashMap 此容器，插入效率不如上面的，因为它做了各种判断和CAS，但是差距不是特别大 读取效率很高，100个线程同时访问，每个线程读取一百万次实测 Hashtable 39s ，SynchronizedHashMap 38s ，ConcurrentHashMap 1.7s 前两个将近40秒，ConcurrentHashMap只需要不到2s，由此可见此容器读取效率极高 2、为什么推荐使用Queue来做高并发 为什么推荐Queue（队列） Queue接口提供了很多针对多线程非常友好的API（offer ，peek和poll，其中BlockingQueue还添加了put和take可以阻塞），可以说专门为多线程高并发而创造的接口，所以一般我们使用Queue而不用List 以下代码分别使用链表LinkList和ConcurrentQueue，对比一下速度 LinkList用了5s多，ConcurrentQueue几乎瞬间完成 Concurrent接口就是专为多线程设计，多线程设计要多考虑Queue(高并发用)的使用，少使用List / 有N张火车票，每张票都有一个编号 同时有10个窗口对外售票 请写一个模拟程序 分析下面的程序可能会产生哪些问题？ 重复销售？超量销售？ 使用Vector或者Collections.synchronizedXXX 分析一下，这样能解决问题吗？ 就算操作A和B都是同步的，但A和B组成的复合操作也未必是同步的，仍然需要自己进行同步 就像这个程序，判断size和进行remove必须是一整个的原子操作 @author 马士兵/import java.util.LinkedList;import java.util.List;import java.util.concurrent.TimeUnit;public class TicketSeller3 {static List<String> tickets = new LinkedList<>();static {for(int i=0; i<1000; i++) tickets.add("票 编号：" + i);}public static void main(String[] args) {for(int i=0; i<10; i++) {new Thread(()->{while(true) {synchronized(tickets) {if(tickets.size() <= 0) break;try {TimeUnit.MILLISECONDS.sleep(10);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("销售了--" + tickets.remove(0));} }}).start();} }} 队列 import java.util.Queue;import java.util.concurrent.ConcurrentLinkedQueue;public class TicketSeller4 {static Queue<String> tickets = new ConcurrentLinkedQueue<>();static {for(int i=0; i<1000; i++) tickets.add("票 编号：" + i);}public static void main(String[] args) {for(int i=0; i<10; i++) {new Thread(()->{while(true) {String s = tickets.poll();if(s == null) break;else System.out.println("销售了--" + s);} }).start();} }} 3、多线程常用容器 1、ConcurrentHashMap(无序)和ConcurrentSkipListMap(有序，链表，使用跳表数据结构，让查询更快) 跳表：http://blog.csdn.net/sunxianghuang/article/details/52221913 import java.util.;import java.util.concurrent.ConcurrentHashMap;import java.util.concurrent.ConcurrentSkipListMap;import java.util.concurrent.CountDownLatch;public class T01_ConcurrentMap {public static void main(String[] args) {Map<String, String> map = new ConcurrentHashMap<>();//Map<String, String> map = new ConcurrentSkipListMap<>(); //高并发并且排序//Map<String, String> map = new Hashtable<>();//Map<String, String> map = new HashMap<>(); //Collections.synchronizedXXX//TreeMapRandom r = new Random();Thread[] ths = new Thread[100];CountDownLatch latch = new CountDownLatch(ths.length);long start = System.currentTimeMillis();for(int i=0; i<ths.length; i++) {ths[i] = new Thread(()->{for(int j=0; j<10000; j++) map.put("a" + r.nextInt(100000), "a" + r.nextInt(100000));latch.countDown();});}Arrays.asList(ths).forEach(t->t.start());try {latch.await();} catch (InterruptedException e) {e.printStackTrace();}long end = System.currentTimeMillis();System.out.println(end - start);System.out.println(map.size());} } 2、CopyOnWriteList（写时复制）和CopyOnWriteSet 适用于，高并发是，读的多，写的少的情况 当我们写的时候，将容器复制，让写线程去复制的线程写（写的时候加锁） 而读线程依旧去读旧的(读的时候不加锁) 当写完，将对象指向复制后的已经写完的容器，原来容器销毁 大大提高读的效率 / 写时复制容器 copy on write 多线程环境下，写时效率低，读时效率高 适合写少读多的环境 @author 马士兵/import java.util.ArrayList;import java.util.Arrays;import java.util.List;import java.util.Random;import java.util.Vector;import java.util.concurrent.CopyOnWriteArrayList;public class T02_CopyOnWriteList {public static void main(String[] args) {List<String> lists = //new ArrayList<>(); //这个会出并发问题！//new Vector();new CopyOnWriteArrayList<>();Random r = new Random();Thread[] ths = new Thread[100];for(int i=0; i<ths.length; i++) {Runnable task = new Runnable() {@Overridepublic void run() {for(int i=0; i<1000; i++) lists.add("a" + r.nextInt(10000));} };ths[i] = new Thread(task);}runAndComputeTime(ths);System.out.println(lists.size());}static void runAndComputeTime(Thread[] ths) {long s1 = System.currentTimeMillis();Arrays.asList(ths).forEach(t->t.start());Arrays.asList(ths).forEach(t->{try {t.join();} catch (InterruptedException e) {e.printStackTrace();} });long s2 = System.currentTimeMillis();System.out.println(s2 - s1);} } 3、synchronizedList和ConcurrentLinkedQueue package com.mashibing.juc.c_025;import java.util.ArrayList;import java.util.Collections;import java.util.List;import java.util.Queue;import java.util.concurrent.ConcurrentLinkedQueue;public class T04_ConcurrentQueue {public static void main(String[] args) {List<String> strsList = new ArrayList<>();List<String> strsSync = Collections.synchronizedList(strsList);//加锁ListQueue<String> strs = new ConcurrentLinkedQueue<>();//Concurrent链表队列，就是读快for(int i=0; i<10; i++) {strs.offer("a" + i); //add添加，但是不同点是，此方法会返回一个布尔值}System.out.println(strs);System.out.println(strs.size());System.out.println(strs.poll());//取出，取完后将元素去除System.out.println(strs.size());System.out.println(strs.peek());//取出，但是不会将元素从队列删除System.out.println(strs.size());//双端队列Deque} } 4、LinkedBlockingQueue 链表阻塞队列（无界链表，可以一直装东西，直到内存满（其实，也不是无限，其长度Integer.MaxValue就是上限，毕竟最大就这么大）） 主要体现在put和take方法，put添加的时候，如果队列满了，就阻塞当前线程，直到队列有空位，继续插入。take方法取的时候，如果没有值，就阻塞，等有值了，立马去取 import java.util.Random;import java.util.concurrent.BlockingQueue;import java.util.concurrent.LinkedBlockingQueue;import java.util.concurrent.TimeUnit;public class T05_LinkedBlockingQueue {static BlockingQueue<String> strs = new LinkedBlockingQueue<>();static Random r = new Random();public static void main(String[] args) {new Thread(() -> {for (int i = 0; i < 100; i++) {try {strs.put("a" + i); //如果满了，当前线程就会等待（实现阻塞），等多会有空位，将值插入TimeUnit.MILLISECONDS.sleep(r.nextInt(1000));} catch (InterruptedException e) {e.printStackTrace();} }}, "p1").start();for (int i = 0; i < 5; i++) {new Thread(() -> {for (;;) {try {System.out.println(Thread.currentThread().getName() + " take -" + strs.take()); //取内容，如果空了，当前线程就会等待（实现阻塞）} catch (InterruptedException e) {e.printStackTrace();} }}, "c" + i).start();} }} 5、ArrayBlockingQueue 有界阻塞队列（因为Array需要指定长度） import java.util.Random;import java.util.concurrent.ArrayBlockingQueue;import java.util.concurrent.BlockingQueue;import java.util.concurrent.TimeUnit;public class T06_ArrayBlockingQueue {static BlockingQueue<String> strs = new ArrayBlockingQueue<>(10);static Random r = new Random();public static void main(String[] args) throws InterruptedException {for (int i = 0; i < 10; i++) {strs.put("a" + i);}//strs.put("aaa"); //满了就会等待，程序阻塞//strs.add("aaa");//strs.offer("aaa");strs.offer("aaa", 1, TimeUnit.SECONDS);System.out.println(strs);} } 6、特殊的阻塞队列1：DelayQueue 延时队列（按时间进行调度，就是隔多长时间运行，谁隔的少，谁先） 以下例子中，我们添加线程到队列顺序为t12345，正常情况下，会按照顺序运行，但是这里有了延时时间，也就是时间越短，越先执行 步骤很简单，拿到延时队列 指定构造方法 继承 implements Delayed 重写 compareTo和getDelay import java.util.Calendar;import java.util.Random;import java.util.concurrent.BlockingQueue;import java.util.concurrent.DelayQueue;import java.util.concurrent.Delayed;import java.util.concurrent.TimeUnit;public class T07_DelayQueue {static BlockingQueue<MyTask> tasks = new DelayQueue<>();static Random r = new Random();static class MyTask implements Delayed {String name;long runningTime;MyTask(String name, long rt) {this.name = name;this.runningTime = rt;}@Overridepublic int compareTo(Delayed o) {if(this.getDelay(TimeUnit.MILLISECONDS) < o.getDelay(TimeUnit.MILLISECONDS))return -1;else if(this.getDelay(TimeUnit.MILLISECONDS) > o.getDelay(TimeUnit.MILLISECONDS)) return 1;else return 0;}@Overridepublic long getDelay(TimeUnit unit) {return unit.convert(runningTime - System.currentTimeMillis(), TimeUnit.MILLISECONDS);}@Overridepublic String toString() {return name + " " + runningTime;} }public static void main(String[] args) throws InterruptedException {long now = System.currentTimeMillis();MyTask t1 = new MyTask("t1", now + 1000);MyTask t2 = new MyTask("t2", now + 2000);MyTask t3 = new MyTask("t3", now + 1500);MyTask t4 = new MyTask("t4", now + 2500);MyTask t5 = new MyTask("t5", now + 500);tasks.put(t1);tasks.put(t2);tasks.put(t3);tasks.put(t4);tasks.put(t5);System.out.println(tasks);for(int i=0; i<5; i++) {System.out.println(tasks.take());//获取的是toString方法返回值} }} 7、特殊的阻塞队列2：PriorityQueque 优先队列（二叉树算法，就是排序） import java.util.PriorityQueue;public class T07_01_PriorityQueque {public static void main(String[] args) {PriorityQueue<String> q = new PriorityQueue<>();q.add("c");q.add("e");q.add("a");q.add("d");q.add("z");for (int i = 0; i < 5; i++) {System.out.println(q.poll());} }} 8、特殊的阻塞队列3：SynchronusQueue 同步队列(线程池用处非常大) 此队列容量为0，当插入元素时，必须同时有个线程往外取 就是说，当你往这个队列里面插入一个元素，它就拿着这个元素站着(阻塞)，直到有个取元素的线程来，它就把元素交给它 就是用来同步数据的，也就是线程间交互数据用的一个特殊队列 package com.mashibing.juc.c_025;import java.util.concurrent.BlockingQueue;import java.util.concurrent.SynchronousQueue;public class T08_SynchronusQueue { //容量为0public static void main(String[] args) throws InterruptedException {BlockingQueue<String> strs = new SynchronousQueue<>();new Thread(()->{//这个线程就是消费者，来取值try {System.out.println(strs.take());//和同步队列要值} catch (InterruptedException e) {e.printStackTrace();} }).start();strs.put("aaa"); //阻塞等待消费者消费，就拿着aaa站着，等线程来取//strs.put("bbb");//strs.add("aaa");System.out.println(strs.size());} } 9、特殊的阻塞队列4：TransferQueue 传递队列 此队列加入了一个方法transfer()用来向队列添加元素 但是和put()方法不同的是，put添加完元素就走了 而这个方法，添加完自己就阻塞了，直到有人将这个元素取走，它才继续工作(省去我们手动阻塞) import java.util.concurrent.LinkedTransferQueue;public class T09_TransferQueue {public static void main(String[] args) throws InterruptedException {LinkedTransferQueue<String> strs = new LinkedTransferQueue<>();new Thread(() -> {try {System.out.println(strs.take());} catch (InterruptedException e) {e.printStackTrace();} }).start();strs.transfer("aaa");//放东西到队列，同时阻塞等待消费者线程，取走元素//strs.put("aaa");//如果用put就和普通队列一样，放完东西就走了/new Thread(() -> {try {System.out.println(strs.take());} catch (InterruptedException e) {e.printStackTrace();} }).start();/} } 3、线程池 线程池 由于单独创建线程，十分影响效率，而且无法对线程集中管理，一旦疏落，可能线程无限执行，浪费资源 线程池就是一个存储线程的游泳池，而每个线程就是池子里面的赛道 池子里的线程不执行任何任务，只是提供一个资源 而谁提交了任务，比如我想来游泳，那么池子就给你一个赛道，让你游泳 比如它想练憋气，那么给它一个赛道练憋气 当他们用完，走了，那么后面其它人再过来继续用 这就是线程池，始终只有这几个线程，不做实现，而是借用这几个线程的用户，自己掌控用这些线程资源做什么（提交任务给线程,线程空闲就帮他们完成任务） 线程池的两种类型（两类，不是两个） ThreadPoolExecutor（简称TPE） ForkJoinPool（分解汇总任务(将任务细化，最后汇总结果)，少量线程执行多个任务（子任务，TPE做不到先执行子任务），CPU密集型） Executors（注意这后面有s） 它可以说是线程池工厂类，我们一般通过它创建线程池，并且它为我们封装了线程 1、常用类 Executor ExecutorService 扩展了execute方法，具有一个返回值 规定了异步执行机制，提供了一些执行器方法，比如shutdown()关闭等 但是它不知道执行器中的线程何时执行完 Callable 对Runnable进行了扩展,实现Callable的调用，可以有返回值，表示线程的状态 但是无法返回线程执行结果 Future 获得未来线程执行结果 由此，我们可以得知线程池基本的一个使用步骤 其中service.submit（）:为异步提交，也就是说，主线程该干嘛干嘛，我是异步执行的，和同步不一样（当前线程执行完，主线程才能继续执行，叫同步） futuer.get():获取结果集结果，此时因为异步，主线程执行到这里，结果集可能还没封装好，所以此时如果没有值，就阻塞，直到结果集出来 public static void main(String[] args) throws ExecutionException, InterruptedException {Callable<String> c = new Callable() {@Overridepublic String call() throws Exception {return "Hello Callable";} };ExecutorService service = Executors.newCachedThreadPool();Future<String> future = service.submit(c); //异步System.out.println(future.get());//阻塞service.shutdown();} 2、FutureTask 可充当任务的结果集 上面我们介绍Future是用来得到任务的执行结果的 而FutureTask，可以当做一个任务用，并且返回任务的结果，也就是可以跑线程，然后还可以得到线程结果 public static void main(String[] args) throws InterruptedException, ExecutionException {FutureTask<Integer> task = new FutureTask<>(()->{TimeUnit.MILLISECONDS.sleep(500);return 1000;}); //new Callable () { Integer call();}new Thread(task).start();System.out.println(task.get()); //阻塞} 3、CompletableFuture 非常灵活的任务结果集 一个非常灵活的结果集 他可以将很多执行不同任务的线程的结果进行汇总 比如一个网站，它可以启动多个线程去各大电商网站，比如淘宝，京东，收集某些或某一个商品的价格 最后，将获取的数据进行整合封装 最终，客户就可以通过此网站，获取某类商品在各网站的价格信息 / 假设你能够提供一个服务 这个服务查询各大电商网站同一类产品的价格并汇总展示 @author 马士兵 http://mashibing.com/import java.io.IOException;import java.util.Random;import java.util.concurrent.CompletableFuture;import java.util.concurrent.ExecutionException;import java.util.concurrent.TimeUnit;public class T06_01_CompletableFuture {public static void main(String[] args) throws ExecutionException, InterruptedException {long start, end;/start = System.currentTimeMillis();priceOfTM();priceOfTB();priceOfJD();end = System.currentTimeMillis();System.out.println("use serial method call! " + (end - start));/start = System.currentTimeMillis();CompletableFuture<Double> futureTM = CompletableFuture.supplyAsync(()->priceOfTM());CompletableFuture<Double> futureTB = CompletableFuture.supplyAsync(()->priceOfTB());CompletableFuture<Double> futureJD = CompletableFuture.supplyAsync(()->priceOfJD());CompletableFuture.allOf(futureTM, futureTB, futureJD).join();//当所有结果集都获取到，才汇总阻塞CompletableFuture.supplyAsync(()->priceOfTM()).thenApply(String::valueOf).thenApply(str-> "price " + str).thenAccept(System.out::println);end = System.currentTimeMillis();System.out.println("use completable future! " + (end - start));try {System.in.read();} catch (IOException e) {e.printStackTrace();} }private static double priceOfTM() {delay();return 1.00;}private static double priceOfTB() {delay();return 2.00;}private static double priceOfJD() {delay();return 3.00;}/private static double priceOfAmazon() {delay();throw new RuntimeException("product not exist!");}/private static void delay() {int time = new Random().nextInt(500);try {TimeUnit.MILLISECONDS.sleep(time);} catch (InterruptedException e) {e.printStackTrace();}System.out.printf("After %s sleep!\n", time);} } 4、TPE型线程池1：ThreadPoolExecutor 原理及其参数 线程池由两个集合组成，一个集合存储线程，一个集合存储任务 存储线程：可以规定大小，最多可以有多少个，以及指定核心线程数量（不会被回收） 任务队列：存储任务 细节：初始线程池没有线程，当有一个任务来，线程池起一个线程，又有一个任务来，再起一个线程，直到达到核心线程数量 核心线程数量达到时，新来的任务将存储到任务队列中等待核心线程处理完成，直到任务队列也满了 当任务队列满了，此时再次启动一个线程（非核心线程，一旦空闲，达到指定时间将会消失），直到达到线程最大数量 当线程容器和任务容器都满了，又来了线程，将会执行拒绝策略 上面的细节涉及的所有步骤内容，均由创建线程池的参数执行 下面是ThreadPoolExecutor构造方法参数的源码注释 / 用给定的初始值，创建一个新的线程池 @param corePoolSize 核心线程数量 @param maximumPoolSize 最大线程数量 @param keepAliveTime 当线程数大于核心线程数量时，空闲的线程可生存的时间 @param unit 时间单位 @param workQueue 任务队列，只能包含由execute提交的Runnable任务 @param threadFactory 工厂，用于创建线程给线程池调度的工厂，可以自定义 @param handler 拒绝策略(可以自定义，JDK默认提供4种)，当线程边界和队列容量已经满了，新来线程被阻塞时使用的处理程序/public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory,RejectedExecutionHandler handler) JDK提供的4种拒绝策略，不常用，一般都是自己定义拒绝策略 Abort：抛异常 Discard：扔掉，不抛异常 DiscardOldest：扔掉排队时间最久的（将队列中排队时间最久的扔掉，然后让新来的进来） CallerRuns：调用者处理任务（谁通过execute方法提交任务，谁处理） ThreadPoolExecutor继承关系 继承关系：ThreadPoolExecutor->AbstractExectorService类->ExectorService接口->Exector接口 Executors（注意这后面有s） 它可以说是线程池工厂类，我们一般通过它创建线程池，并且它为我们封装了线程 看看下面创建线程池，哪里用到了它 使用实例 import java.io.IOException;import java.util.concurrent.;public class T05_00_HelloThreadPool {static class Task implements Runnable {private int i;public Task(int i) {this.i = i;}@Overridepublic void run() {System.out.println(Thread.currentThread().getName() + " Task " + i);try {System.in.read();} catch (IOException e) {e.printStackTrace();} }@Overridepublic String toString() {return "Task{" +"i=" + i +'}';} }public static void main(String[] args) {ThreadPoolExecutor tpe = new ThreadPoolExecutor(2, 4,60, TimeUnit.SECONDS,new ArrayBlockingQueue<Runnable>(4),Executors.defaultThreadFactory(),new ThreadPoolExecutor.CallerRunsPolicy());//创建线程池，核心2个，最大4个，空闲线程存活时间60s，任务队列容量4，使用默认线程工程，创建线程。拒绝策略是JDK提供的for (int i = 0; i < 8; i++) {tpe.execute(new Task(i));//供提交8次任务}System.out.println(tpe.getQueue());//查看任务队列tpe.execute(new Task(100));//提交新的任务System.out.println(tpe.getQueue());tpe.shutdown();//关闭线程池} } 5、TPE型线程池2：SingleThreadPool 单例线程池(只有一个线程) 为什么有单例线程池 有任务队列，有线程池管理机制 Executors（注意这后面有s） 它可以说是线程池工厂类，我们一般通过它创建线程池，并且它为我们封装了线程 看看下面哪里用到了它 /创建单例线程池，扔5个任务进去，查看输出结果，看看有几个线程执行任务/import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;public class T07_SingleThreadPool {public static void main(String[] args) {ExecutorService service = Executors.newSingleThreadExecutor();for(int i=0; i<5; i++) {final int j = i;service.execute(()->{System.out.println(j + " " + Thread.currentThread().getName());});} }} 6、TPE型线程池3：CachedPool 缓存，存储线程池 此线程池没有核心线程，来一个任务启动一个线程（最多Integer.MaxValue，不会放在任务队列，因为任务队列容量为0），每个线程空闲后，只能活60s 实例 import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;public class T07_SingleThreadPool {public static void main(String[] args) {ExecutorService service = Executors.newSingleThreadExecutor();//通过Executors获取池子for(int i=0; i<5; i++) {final int j = i;service.execute(()->{//提交任务System.out.println(j + " " + Thread.currentThread().getName());});}service.shutdown();} } 7、TPE型线程池4：FixedThreadPool 固定线程池 此线次池，用于创建一个固定线程数量的线程池，不会回收 实例 import java.util.ArrayList;import java.util.List;import java.util.concurrent.Callable;import java.util.concurrent.ExecutionException;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import java.util.concurrent.Future;public class T09_FixedThreadPool {public static void main(String[] args) throws InterruptedException, ExecutionException {//并发执行long start = System.currentTimeMillis();getPrime(1, 200000); long end = System.currentTimeMillis();System.out.println(end - start);//输出并发执行耗费时间final int cpuCoreNum = 4;//并行执行ExecutorService service = Executors.newFixedThreadPool(cpuCoreNum);MyTask t1 = new MyTask(1, 80000); //1-5 5-10 10-15 15-20MyTask t2 = new MyTask(80001, 130000);MyTask t3 = new MyTask(130001, 170000);MyTask t4 = new MyTask(170001, 200000);Future<List<Integer>> f1 = service.submit(t1);Future<List<Integer>> f2 = service.submit(t2);Future<List<Integer>> f3 = service.submit(t3);Future<List<Integer>> f4 = service.submit(t4);start = System.currentTimeMillis();f1.get();f2.get();f3.get();f4.get();end = System.currentTimeMillis();System.out.println(end - start);//输出并行耗费时间}static class MyTask implements Callable<List<Integer>> {int startPos, endPos;MyTask(int s, int e) {this.startPos = s;this.endPos = e;}@Overridepublic List<Integer> call() throws Exception {List<Integer> r = getPrime(startPos, endPos);return r;} }static boolean isPrime(int num) {for(int i=2; i<=num/2; i++) {if(num % i == 0) return false;}return true;}static List<Integer> getPrime(int start, int end) {List<Integer> results = new ArrayList<>();for(int i=start; i<=end; i++) {if(isPrime(i)) results.add(i);}return results;} } 8、TPE型线程池5：ScheduledPool 预定，延时线程池 根据延时时间（隔多长时间后运行），排序，哪个线程先执行,用户只需要指定核心线程数量 此线程池返回的池对象，和提交任务方法都不一样，比较涉及到时间 import java.util.Random;import java.util.concurrent.Executors;import java.util.concurrent.ScheduledExecutorService;import java.util.concurrent.TimeUnit;public class T10_ScheduledPool {public static void main(String[] args) {ScheduledExecutorService service = Executors.newScheduledThreadPool(4);service.scheduleAtFixedRate(()->{//提交延时任务try {TimeUnit.MILLISECONDS.sleep(new Random().nextInt(1000));} catch (InterruptedException e) {e.printStackTrace();}System.out.println(Thread.currentThread().getName());}, 0, 500, TimeUnit.MILLISECONDS);//指定延时时间和单位，第一个任务延时0毫秒，之后的任务，延时500毫秒} } 9、手写拒绝策略小例子 import java.util.concurrent.;public class T14_MyRejectedHandler {public static void main(String[] args) {ExecutorService service = new ThreadPoolExecutor(4, 4,0, TimeUnit.SECONDS, new ArrayBlockingQueue<>(6),Executors.defaultThreadFactory(),new MyHandler());//将手写拒绝策略传入}static class MyHandler implements RejectedExecutionHandler {//1、继承RejectedExecutionHandler@Overridepublic void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {//2、重写方法//log("r rejected")//伪代码，表示通过log4j.log()报一下日志，拒绝的时间，线程名//save r kafka mysql redis//可以尝试保存队列//try 3 times //可以尝试几次，比如3次，重新去抢队列，3次还不行就丢弃if(executor.getQueue().size() < 10000) {//尝试条件，如果size>10000了,就执行拒绝策略//try put again();//如果小于10000，尝试将其放到队列中} }} } 10、ForkJoinPool线程池1：ForkJoinPool 前面我们讲过线程分为两大类，TPE和FJP ForkJoinPool（分解汇总任务(将任务细化，最后汇总结果)，少量线程执行多个任务（子任务，TPE做不到先执行子任务），CPU密集型） 适合将大任务切分成多个小任务运行 两个方法，fork()：分子任务，将子任务分配到线程池中 join()：当前任务的计算结果，如果有子任务，等子任务结果返回后再汇总 下面实例实现，一百万个随机数求和，由两种方法实现，一种ForkJoinPool分任务并行，一种使用单线程做 import java.io.IOException;import java.util.Arrays;import java.util.Random;import java.util.concurrent.ForkJoinPool;import java.util.concurrent.RecursiveAction;import java.util.concurrent.RecursiveTask;public class T12_ForkJoinPool {//1000000个随机数求和static int[] nums = new int[1000000];//一堆数static final int MAX_NUM = 50000;//分任务时，每个任务的操作量不能多于50000个，否则就继续细分static Random r = new Random();//使用随机数将数组初始化static {for(int i=0; i<nums.length; i++) {nums[i] = r.nextInt(100);}System.out.println("---" + Arrays.stream(nums).sum()); //stream api 单线程就这么做，一个一个加}//分任务，需要继承，可以继承RecursiveAction(不需要返回值，一般用在不需要返回值的场景)或//RecursiveTask(需要返回值，我们用这个，因为我们需要最后获取求和结果)两个更好实现的类，//他俩继承与ForkJoinTaskstatic class AddTaskRet extends RecursiveTask<Long> {private static final long serialVersionUID = 1L;int start, end;AddTaskRet(int s, int e) {start = s;end = e;}@Overrideprotected Long compute() {if(end-start <= MAX_NUM) {//如果任务操作数小于规定的最大操作数，就进行运算，long sum = 0L;for(int i=start; i<end; i++) sum += nums[i];return sum;//返回结果} //如果分配的操作数大于规定，就继续细分（简单的重中点分，两半）int middle = start + (end-start)/2;//获取中间值AddTaskRet subTask1 = new AddTaskRet(start, middle);//传入起始值和中间值，表示一个子任务AddTaskRet subTask2 = new AddTaskRet(middle, end);//中间值和结尾值，表示一个子任务subTask1.fork();//分任务subTask2.fork();//分任务return subTask1.join() + subTask2.join();//最后返回结果汇总} }public static void main(String[] args) throws IOException {/ForkJoinPool fjp = new ForkJoinPool();AddTask task = new AddTask(0, nums.length);fjp.execute(task);/ForkJoinPool fjp = new ForkJoinPool();//创建线程池AddTaskRet task = new AddTaskRet(0, nums.length);//创建任务fjp.execute(task);//传入任务long result = task.join();//返回汇总结果System.out.println(result);//System.in.read();} } 11、ForkJoinPool线程池2：WorkStealingPool 任务偷取线程池 原来的线程池，都是有一个任务队列，而这个不同，它给每个线程都分配了一个任务队列 当某一个线程的任务队列没有任务，并且自己空闲，它就去其它线程的任务队列中偷任务，所以叫任务偷取线程池 细节：当线程自己从自己的任务队列拿任务时，不需要加锁，但是偷任务时，因为有两个线程，可能发生同步问题，需要加锁 此线程继承FJP 实例 import java.io.IOException;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import java.util.concurrent.TimeUnit;public class T11_WorkStealingPool {public static void main(String[] args) throws IOException {ExecutorService service = Executors.newWorkStealingPool();System.out.println(Runtime.getRuntime().availableProcessors());service.execute(new R(1000));service.execute(new R(2000));service.execute(new R(2000));service.execute(new R(2000)); //daemonservice.execute(new R(2000));//由于产生的是精灵线程（守护线程、后台线程），主线程不阻塞的话，看不到输出System.in.read(); }static class R implements Runnable {int time;R(int t) {this.time = t;}@Overridepublic void run() {try {TimeUnit.MILLISECONDS.sleep(time);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(time + " " + Thread.currentThread().getName());} }} 12、流式API：ParallelStreamAPI 不懂的请参考：https://blog.csdn.net/grd_java/article/details/110265219 实例 import java.util.ArrayList;import java.util.List;import java.util.Random;public class T13_ParallelStreamAPI {public static void main(String[] args) {List<Integer> nums = new ArrayList<>();Random r = new Random();for(int i=0; i<10000; i++) nums.add(1000000 + r.nextInt(1000000));//System.out.println(nums);long start = System.currentTimeMillis();nums.forEach(v->isPrime(v));long end = System.currentTimeMillis();System.out.println(end - start);//使用parallel stream apistart = System.currentTimeMillis();nums.parallelStream().forEach(T13_ParallelStreamAPI::isPrime);//并行流，将任务切分成子任务执行end = System.currentTimeMillis();System.out.println(end - start);}static boolean isPrime(int num) {for(int i=2; i<=num/2; i++) {if(num % i == 0) return false;}return true;} } 13、总结 总结 Callable相当于一Runnable但是它有返回值 Future：存储执行完产生的结果 FutureTask 相当于Future+Runnable，既可以执行任务，又能获取任务执行的Future结果 CompletableFuture 可以多任务异步，并对多任务控制，整合任务结果，细化完美，比如可以一个任务完成就可以整合结果，也可以所有任务完成才整合结果 4、ThreadPoolExecutor源码解析 依然只讲重点，实际还需要大家按照上篇博客中看源码的方式来看 1、常用变量的解释 // 1. ctl，可以看做一个int类型的数字，高3位表示线程池状态，低29位表示worker数量private final AtomicInteger ctl = new AtomicInteger(ctlOf(RUNNING, 0));// 2. COUNT_BITS，Integer.SIZE为32，所以COUNT_BITS为29private static final int COUNT_BITS = Integer.SIZE - 3;// 3. CAPACITY，线程池允许的最大线程数。1左移29位，然后减1，即为 2^29 - 1private static final int CAPACITY = (1 << COUNT_BITS) - 1;// runState is stored in the high-order bits// 4. 线程池有5种状态，按大小排序如下：RUNNING < SHUTDOWN < STOP < TIDYING < TERMINATEDprivate static final int RUNNING = -1 << COUNT_BITS;private static final int SHUTDOWN = 0 << COUNT_BITS;private static final int STOP = 1 << COUNT_BITS;private static final int TIDYING = 2 << COUNT_BITS;private static final int TERMINATED = 3 << COUNT_BITS;// Packing and unpacking ctl// 5. runStateOf()，获取线程池状态，通过按位与操作，低29位将全部变成0private static int runStateOf(int c) { return c & ~CAPACITY; }// 6. workerCountOf()，获取线程池worker数量，通过按位与操作，高3位将全部变成0private static int workerCountOf(int c) { return c & CAPACITY; }// 7. ctlOf()，根据线程池状态和线程池worker数量，生成ctl值private static int ctlOf(int rs, int wc) { return rs | wc; }/ Bit field accessors that don't require unpacking ctl. These depend on the bit layout and on workerCount being never negative./// 8. runStateLessThan()，线程池状态小于xxprivate static boolean runStateLessThan(int c, int s) {return c < s;}// 9. runStateAtLeast()，线程池状态大于等于xxprivate static boolean runStateAtLeast(int c, int s) {return c >= s;} 2、构造方法 public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory,RejectedExecutionHandler handler) {// 基本类型参数校验if (corePoolSize < 0 ||maximumPoolSize <= 0 ||maximumPoolSize < corePoolSize ||keepAliveTime < 0)throw new IllegalArgumentException();// 空指针校验if (workQueue == null || threadFactory == null || handler == null)throw new NullPointerException();this.corePoolSize = corePoolSize;this.maximumPoolSize = maximumPoolSize;this.workQueue = workQueue;// 根据传入参数unit和keepAliveTime，将存活时间转换为纳秒存到变量keepAliveTime 中this.keepAliveTime = unit.toNanos(keepAliveTime);this.threadFactory = threadFactory;this.handler = handler;} 3、提交执行task的过程 public void execute(Runnable command) {if (command == null)throw new NullPointerException();/ Proceed in 3 steps: 1. If fewer than corePoolSize threads are running, try to start a new thread with the given command as its first task. The call to addWorker atomically checks runState and workerCount, and so prevents false alarms that would add threads when it shouldn't, by returning false. 2. If a task can be successfully queued, then we still need to double-check whether we should have added a thread (because existing ones died since last checking) or that the pool shut down since entry into this method. So we recheck state and if necessary roll back the enqueuing if stopped, or start a new thread if there are none. 3. If we cannot queue task, then we try to add a new thread. If it fails, we know we are shut down or saturated and so reject the task./int c = ctl.get();// worker数量比核心线程数小，直接创建worker执行任务if (workerCountOf(c) < corePoolSize) {if (addWorker(command, true))return;c = ctl.get();}// worker数量超过核心线程数，任务直接进入队列if (isRunning(c) && workQueue.offer(command)) {int recheck = ctl.get();// 线程池状态不是RUNNING状态，说明执行过shutdown命令，需要对新加入的任务执行reject()操作。// 这儿为什么需要recheck，是因为任务入队列前后，线程池的状态可能会发生变化。if (! isRunning(recheck) && remove(command))reject(command);// 这儿为什么需要判断0值，主要是在线程池构造方法中，核心线程数允许为0else if (workerCountOf(recheck) == 0)addWorker(null, false);}// 如果线程池不是运行状态，或者任务进入队列失败，则尝试创建worker执行任务。// 这儿有3点需要注意：// 1. 线程池不是运行状态时，addWorker内部会判断线程池状态// 2. addWorker第2个参数表示是否创建核心线程// 3. addWorker返回false，则说明任务执行失败，需要执行reject操作else if (!addWorker(command, false))reject(command);} 4、addworker源码解析 private boolean addWorker(Runnable firstTask, boolean core) {retry:// 外层自旋for (;;) {int c = ctl.get();int rs = runStateOf(c);// 这个条件写得比较难懂，我对其进行了调整，和下面的条件等价// (rs > SHUTDOWN) || // (rs == SHUTDOWN && firstTask != null) || // (rs == SHUTDOWN && workQueue.isEmpty())// 1. 线程池状态大于SHUTDOWN时，直接返回false// 2. 线程池状态等于SHUTDOWN，且firstTask不为null，直接返回false// 3. 线程池状态等于SHUTDOWN，且队列为空，直接返回false// Check if queue empty only if necessary.if (rs >= SHUTDOWN &&! (rs == SHUTDOWN &&firstTask == null &&! workQueue.isEmpty()))return false;// 内层自旋for (;;) {int wc = workerCountOf(c);// worker数量超过容量，直接返回falseif (wc >= CAPACITY ||wc >= (core ? corePoolSize : maximumPoolSize))return false;// 使用CAS的方式增加worker数量。// 若增加成功，则直接跳出外层循环进入到第二部分if (compareAndIncrementWorkerCount(c))break retry;c = ctl.get(); // Re-read ctl// 线程池状态发生变化，对外层循环进行自旋if (runStateOf(c) != rs)continue retry;// 其他情况，直接内层循环进行自旋即可// else CAS failed due to workerCount change; retry inner loop} }boolean workerStarted = false;boolean workerAdded = false;Worker w = null;try {w = new Worker(firstTask);final Thread t = w.thread;if (t != null) {final ReentrantLock mainLock = this.mainLock;// worker的添加必须是串行的，因此需要加锁mainLock.lock();try {// Recheck while holding lock.// Back out on ThreadFactory failure or if// shut down before lock acquired.// 这儿需要重新检查线程池状态int rs = runStateOf(ctl.get());if (rs < SHUTDOWN ||(rs == SHUTDOWN && firstTask == null)) {// worker已经调用过了start()方法，则不再创建workerif (t.isAlive()) // precheck that t is startablethrow new IllegalThreadStateException();// worker创建并添加到workers成功workers.add(w);// 更新largestPoolSize变量int s = workers.size();if (s > largestPoolSize)largestPoolSize = s;workerAdded = true;} } finally {mainLock.unlock();}// 启动worker线程if (workerAdded) {t.start();workerStarted = true;} }} finally {// worker线程启动失败，说明线程池状态发生了变化（关闭操作被执行），需要进行shutdown相关操作if (! workerStarted)addWorkerFailed(w);}return workerStarted;} 5、线程池worker任务单元 private final class Workerextends AbstractQueuedSynchronizerimplements Runnable{/ This class will never be serialized, but we provide a serialVersionUID to suppress a javac warning./private static final long serialVersionUID = 6138294804551838833L;/ Thread this worker is running in. Null if factory fails. /final Thread thread;/ Initial task to run. Possibly null. /Runnable firstTask;/ Per-thread task counter /volatile long completedTasks;/ Creates with given first task and thread from ThreadFactory. @param firstTask the first task (null if none)/Worker(Runnable firstTask) {setState(-1); // inhibit interrupts until runWorkerthis.firstTask = firstTask;// 这儿是Worker的关键所在，使用了线程工厂创建了一个线程。传入的参数为当前workerthis.thread = getThreadFactory().newThread(this);}/ Delegates main run loop to outer runWorker /public void run() {runWorker(this);}// 省略代码...} 6、核心线程执行逻辑-runworker final void runWorker(Worker w) {Thread wt = Thread.currentThread();Runnable task = w.firstTask;w.firstTask = null;// 调用unlock()是为了让外部可以中断w.unlock(); // allow interrupts// 这个变量用于判断是否进入过自旋（while循环）boolean completedAbruptly = true;try {// 这儿是自旋// 1. 如果firstTask不为null，则执行firstTask；// 2. 如果firstTask为null，则调用getTask()从队列获取任务。// 3. 阻塞队列的特性就是：当队列为空时，当前线程会被阻塞等待while (task != null || (task = getTask()) != null) {// 这儿对worker进行加锁，是为了达到下面的目的// 1. 降低锁范围，提升性能// 2. 保证每个worker执行的任务是串行的w.lock();// If pool is stopping, ensure thread is interrupted;// if not, ensure thread is not interrupted. This// requires a recheck in second case to deal with// shutdownNow race while clearing interrupt// 如果线程池正在停止，则对当前线程进行中断操作if ((runStateAtLeast(ctl.get(), STOP) ||(Thread.interrupted() &&runStateAtLeast(ctl.get(), STOP))) &&!wt.isInterrupted())wt.interrupt();// 执行任务，且在执行前后通过beforeExecute()和afterExecute()来扩展其功能。// 这两个方法在当前类里面为空实现。try {beforeExecute(wt, task);Throwable thrown = null;try {task.run();} catch (RuntimeException x) {thrown = x; throw x;} catch (Error x) {thrown = x; throw x;} catch (Throwable x) {thrown = x; throw new Error(x);} finally {afterExecute(task, thrown);} } finally {// 帮助gctask = null;// 已完成任务数加一 w.completedTasks++;w.unlock();} }completedAbruptly = false;} finally {// 自旋操作被退出，说明线程池正在结束processWorkerExit(w, completedAbruptly);} } 本篇文章为转载内容。原文链接：https://blog.csdn.net/grd_java/article/details/113116244。 该文由互联网用户投稿提供，文中观点代表作者本人意见，并不代表本站的立场。 作为信息平台，本站仅提供文章转载服务，并不拥有其所有权，也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况，请及时联系我们，我们将第一时间进行核实并删除相应内容。

...vaScript函数参数和实参的概念及其关系是前端开发中的基础且关键部分，随着技术的演进，这一领域的理解和应用也在不断深化。近期，ECMAScript 2021（ES12）中引入了新的函数参数特性——可选链操作符在函数调用中的使用，使得处理嵌套对象作为实参时更加简洁灵活。例如，在以往版本的JavaScript中，若要访问深层嵌套的属性作为函数参数，可能会遇到undefined的错误，而现在通过?.操作符可以安全地进行条件访问。 此外，函数式编程范式在JavaScript社区日渐流行，对函数参数与实参的探讨也延伸到了柯里化、偏函数等高级技巧上。这些技术能帮助开发者更好地管理复杂性，提升代码复用率，尤其是在处理大量数据或构建组件库时表现尤为突出。 同时，TypeScript作为JavaScript的超集，其严格的类型系统对于函数参数和实参的约束更是细致入微，包括可选参数、默认参数以及联合类型和泛型的应用，不仅提高了代码的健壮性，更极大地优化了开发体验和团队协作效率。 因此，深入理解并掌握JavaScript函数参数与实参的工作机制，并紧跟最新语言特性和编程范式的演进，无疑将助力开发者在实际项目中编写出更高效、更具弹性的代码。

...义，能够处理多种不同类型的参数。这种机制极大地增强了代码的复用性和灵活性。不过，想要把这些模板真正用起来，我们得先搞明白怎么把它们具象化，并且实实在在地掌握住这个技巧。本文将通过实例和深入探讨来揭示这一过程。 1. 函数模板的基本概念 首先，让我们通过一个简单的函数模板例子来直观感受一下： cpp template T max(T a, T b) { return (a > b) ? a : b; } 在这个例子中，max是一个函数模板，其接受两个相同类型的参数a和b，并返回两者中的较大值。这里的typename T是一个占位符，表示任意类型，当我们在程序中使用这个模板时，编译器会根据传入的实际参数类型自动替换T。 2. 函数模板的具体化过程 2.1 自动具体化 当我们在代码中调用max函数，并传入特定类型的参数时，编译器会自动进行模板的具体化。例如： cpp int main() { int x = 10, y = 20; int result = max(x, y); // 这里编译器自动将T替换成int类型 std::cout << "Max of x and y: " << result << std::endl; double a = 3.14, b = 2.71; double result2 = max(a, b); // 这里编译器自动将T替换成double类型 std::cout << "Max of a and b: " << result2 << std::endl; return 0; } 在这段代码中，当我们分别使用int和double类型调用max函数时，编译器就会为每种情况生成一份特定版本的函数代码，这就是所谓的函数模板的具体化。 2.2 显式具体化 除了编译器自动具体化之外，我们还可以显式地指定函数模板的具体类型。这通常用于解决某些特殊场景下编译器无法准确推断类型的情况。例如： cpp template <> char max(char a, char b) { std::cout << "Specific version for char type." << std::endl; return (a > b) ? a : b; } int main() { char c1 = 'A', c2 = 'Z'; char max_char = max(c1, c2); // 这里直接调用显式具体化的char版本函数 return 0; } 这里，我们显式地为char类型定义了max函数的具体版本。在调用时，即使没有类型推断，也会直接使用这个特化的版本。 3. 总结与思考 函数模板的具体化是C++编程中一项重要的技巧，它既能提升代码的复用性，又能帮助我们实现更为灵活的编程设计。你知道吗？只要咱们掌握了自动具体化和显式具体化这两种神奇招数，就能把模板玩得溜溜的，写出既高效又方便维护的C++代码，让编程这件事儿变得轻松又愉快！ 然而，在享受模板带来的便利的同时，也要注意避免过度泛化导致的代码难以理解和维护的问题。所以在实际编程干活的时候，咱们得瞅准具体的业务需求，灵活巧妙地运用和定制函数模板，把C++那牛哄哄的强类型特性榨干最后一滴油，让它发挥到极致。

...指针是一种特殊的指针类型，用于存储类的非静态成员函数的地址。通过声明成员函数指针变量并将其初始化为类成员函数的地址，可以在运行时动态决定调用哪个对象的哪个成员函数。调用成员函数指针时需要结合对象实例进行解引用操作。 模板函数 , 模板函数是C++中的泛型编程工具，允许程序员编写能够在多种数据类型上通用的函数。在文章中提到的callMemberFunc就是一个模板函数，其参数包括对象指针、成员函数指针以及可能的参数列表。编译器会在使用模板函数时根据传入的实际类型生成对应的函数实例，从而实现对不同类型对象及其成员函数的统一处理和调用。

...常见应用场景： 1）类型参数的自动推导：当我们调用一个带有类型参数的方法时，Scala会尝试寻找与该类型参数匹配的隐式值。例如： java def foo[T](t: T): Unit = { println(s"The type of t is $t") } foo("Hello, World!") 在这个例子中，Scala会尝试找到一个可以将字符串转换为T类型的隐式转换，并且找到了scala.Predef.StringOpstoString的隐式转换。 2）隐式转换类：Scala中的隐式转换不仅可以应用于类型参数，也可以应用于对象。例如： java class RichString(val str: String) extends AnyVal { def startsWith(prefix: String): Boolean = str.startsWith(prefix) } object RichString { implicit val stringRich: RichString = new RichString("") } val richStr = "Hello, World!" richStr.startsWith("Hello") 在这个例子中，Scala会尝试找到一个可以将String转换为RichString类型的隐式转换，并且找到了RichString对象。 3）隐式参数解析：我们可以通过在方法或函数的参数列表中声明一个类型为隐式的参数，然后让编译器在编译期间自动推导出该隐式参数的值。例如： java import scala.math.sqrt def area(radius: Double)(implicit ev: => Double = sqrt(4)): Double = { Math.PI radius radius } area(5) 在这个例子中，Scala会尝试找到一个可以将Double转换为Double类型的隐式转换，并且找到了scala.math.sqrt的隐式转换。 序号3：Scala中的隐式转换原理 Scala中的隐式转换是一种编译时机制，它允许我们在代码中省略某些显式类型声明。当你在用Scala编程时，如果编译器找不到一个恰好匹配特定类型的明确类型声明，它就会像个侦探一样，在当前的作用域范围内搜寻一番，看看是否藏着符合要求的隐式类型转换“小秘密”。如果碰巧找到了这样一个隐式转换，编译器就会在程序运行的时候，悄无声息地执行这个转换操作，把参数的类型自动变成目标类型所需要的样子。 例如，考虑下面的代码片段： java class MyClass { val myVar: Int = 5 } val obj = new MyClass() println(obj.myVar + " Hello") // 编译错误 在这个例子中，Scala编译器无法将MyClass的实例转换为String类型，因为没有定义这样的转换。如果我们想要使用隐式转换来解决这个问题，我们可以这样做： java object MyImplicits { implicit val intToString: Int => String = _.toString } val obj = new MyClass() println(MyImplicits.intToString(obj.myVar) + " Hello") // 输出：5 Hello 在这个例子中，我们定义了一个名为intToString的隐式转换，它可以将Int类型转换为String类型。然后我们将这个隐式转换引入到我们的代码中，使得在调用println(obj.myVar + " Hello")时，Scala编译器可以找到这个隐式转换并将其用于将obj.myVar转换为String类型。 总的来说，Scala中的隐式转换是一个强大的工具，它可以帮助我们写出更简洁、更易于理解的代码。但是，咱们也得留个心眼儿，别乱用隐式转换，要不然代码可能会变得让人摸不着头脑，维护起来也够你头疼的。

高级类型系统：Existential Types的存在类型 在Scala中，类型系统是非常强大的工具，它允许我们定义复杂的类型，并且可以灵活地控制它们的行为。其中一种非常有用的类型是存在类型（Existential Types），它可以让我们处理不确定类型的值。在这篇文章中，我们将深入探讨这个概念。 什么是Existential Types？ 简单来说，Existential Types是一种可以在类型声明中省略一些特定参数的方法。例如，我们可以创建一个类型，该类型表示所有满足某个条件的对象。这种类型的东东呢，我们给它起了个名儿叫“存在类型”，为啥这么叫嘞？因为它只告诉你某个东西确实存在，但关于这玩意儿到底是个啥类型的具体情况，它就笑而不语，保密得严严实实滴。 scala val box: Any = "Hello, World!" 在这个例子中，Any是一个存在类型。虽然我们知道box实际上是字符串，但我们不能确定这一点。这是因为在编译时，Scala不知道box的具体类型。 使用Existential Types的好处 Existential Types有几个重要的优点： - 它们提供了灵活性。由于咱们没规定具体的类型限制，所以完全可以把各种不同类型的数据一股脑儿塞进同一个容器里头。 - 它们增强了泛型编程的能力。咱们能够利用 Existential Types 这个利器，妥妥地应对各种不确定性的问题，特别是在处理那些涉及不同类型对象交互操作的场景时，那可真是帮了大忙了！ - 它们可以提高程序的性能。要是我们清楚数据将来是要拿去做某个特定操作的，那么采用 Existential Types 就能大大减轻类型检查的负担，让工作变得更轻松。 如何使用Existential Types 让我们来看几个使用Existential Types的例子。 1. 泛型方法 我们可以使用Existential Types来编写泛型方法，这些方法可以接受任何类型的数据，并对其进行某种操作。 scala def applyOnAny[A](x: A)(f: A => String): String = s"The result of applying $f on $x is ${f(x)}" println(applyOnAny("Hello")(_ + "!")) // 输出: The result of applying _ + ! on Hello is Hello! 在这个例子中，我们的函数 applyOnAny 接受两个参数：一个是未知类型 A 的值 x ，另一个是一个将 A 转换为字符串的函数 f 。然后，它调用 f 并返回结果。 2. 包装器类 我们可以使用Existential Types来创建包装器类，这些类可以将任意类型的值封装到一个新的类型中。 scala class Box[T](val value: T) { override def toString: String = s"Box($value)" } val stringBox = new Box[String]("Hello") val intBox = new Box[Int](5) println(stringBox.toString) // 输出: Box(Hello) println(intBox.toString) // 输出: Box(5) 在这个例子中，我们的 Box 类可以封装任何类型的数据。当我们创建新的 Box 对象时，我们传递了我们要包装的值以及它的类型。 3. 模式匹配 我们可以使用Existential Types来进行模式匹配，这使得我们可以处理各种不同的类型。 scala def test(s: Any): Unit = s match { case Some(x) => println(x) case None => println("None") } test(Some(5)) // 输出: 5 test(None) // 输出: None 在这个例子中，我们的函数 test 接受一个 Any 值作为参数，并尝试将其转换为 Some[_] 或 None 对象。如果可以成功转换，则打印出对应的值。 总的来说，Existential Types 是 Scala 中非常强大和有用的特性。通过使用它们，我们可以更好地处理不确定性，并编写更灵活和高效的代码。

...ption是一个特定类型的异常，当尝试通过键从Dictionary或其他关联键值对的集合类中获取对应值，而该键实际上并未存在于集合中时，由系统抛出。此异常提示开发者尝试访问的数据不存在，需要进行错误处理或预先检查以确保键的有效性。 Dictionary , 在.NET编程中，Dictionary是一种泛型集合类型，它实现了IDictionary<TKey, TValue>接口，提供了一种基于键高效查找和存储数据的方法。Dictionary将每个键与其关联的值相关联，允许通过键快速检索对应的值，并且保证了键的唯一性。在文章中，Dictionary是引发KeyNotFoundException的主要场景之一。 TryGetValue方法 , TryGetValue是.NET框架中Dictionary类提供的一个实例方法，用于安全地获取与指定键关联的值。该方法接受两个参数。

...vy格式化字符串缺失参数异常 1. 引言 在我们的编程旅程中，错误和异常是难以避免的“朋友”，它们往往是我们程序逻辑的警示灯。今天咱们要聊的话题呢，就是Groovy语言捣鼓格式化字符串时，可能会蹦出的一个叫groovylangMissingFormatArgumentException的典型小错误。想象一下，就像是你在给一首歌编曲时，不小心漏掉了一个音符，Groovy这小子就可能跟你急眼，抛出这么个异常来提醒你：“喂喂喂，你的格式字符串里少了个东西！”它直接了当地跟我们打了个招呼：“喂，老兄，你在用格式化字符串时好像忘给参数啦！”接下来，咱就一块儿借助实例代码，一步一步地解析，再唠唠嗑探讨探讨，把这异常背后的秘密给揪出来。 2. Groovy格式化字符串基础 在Groovy的世界里，我们可以像Java中的String.format()方法一样，利用占位符进行字符串格式化。例如： groovy def name = "Alice" def age = 25 println "%s is %d years old.".format(name, age) // 输出: Alice is 25 years old. 上述代码中，%s代表字符串类型参数，%d则对应整型参数。当我们在调用format()方法时，需要提供与占位符数量相匹配的参数。 3. groovylangMissingFormatArgumentException详析 那么，当我们提供的参数数量不足以匹配格式化字符串中的占位符时，就会触发groovylangMissingFormatArgumentException异常。看下面的例子： groovy def name = "Bob" println "%s is %d years old and lives in %s.".format(name) // 抛出 groovylangMissingFormatArgumentException // 或者更直观地 try { "%s is %d years old and lives in %s.".format("Alice") } catch (groovylangMissingFormatArgumentException e) { println "Oops! Caught an exception: ${e.message}" // 输出: Oops! Caught an exception: Missing argument for format string at index 2. } 在这段代码中，我们只提供了一个人名作为参数，而格式化字符串中有两个 %s 占位符和一个 %d 占位符，总共需要三个参数，这就导致了groovylangMissingFormatArgumentException异常的发生。 4. 解决方案与思考过程 面对这种问题，我们的首要任务就是检查并确保传递给format()方法的参数数量与格式化字符串中的占位符数量一致。这其实是个典型的编程小bug，你就得像个侦探一样，瞪大眼睛仔仔细细地审查每一行代码，逐一对比，慢慢就能揪出问题，然后手起刀落，轻松修复它。 groovy def name = "Charlie" def age = 30 def location = "New York" println "%s is %d years old and lives in %s.".format(name, age, location) // 正确输出: Charlie is 30 years old and lives in New York. 在此过程中，我们需要不断自问：我是否正确理解了每个占位符所对应的参数类型？我是否提供了足够的参数？这样的思考方式有助于我们在编码过程中养成严谨的习惯，避免类似异常的发生。 5. 结语 总的来说，groovylangMissingFormatArgumentException是一个非常直观且易于理解和解决的异常。嘿，你知道吗？当我们用Groovy这个小家伙进行字符串格式化时，千万可别马虎大意了，一定要瞪大眼睛，对参数的数量和类型把好关！咱们带着这份小心谨慎，在编程的世界里游刃有余，确保每一次字符串格式化的动作都精准无比，就像精心排布一首诗一样，每一个字都闪耀着智慧的光芒，整体韵律流畅又协调。

...函数能够处理多种数据类型。函数模板通过使用占位符（如typename T或class T）来表示未知类型，编译器会在编译时根据传入的实际参数类型生成相应的特定版本函数。 模板具体化 , 在C++中，模板具体化是指将一个泛化的函数模板实例化为针对特定类型的特化版本的过程。编译器会根据函数调用时提供的实际类型信息，自动生成与该类型匹配的函数实现，或者开发者可以明确指定类型进行显式具体化。 泛型编程 , 泛型编程是一种编程范式，在C++中主要通过模板机制实现。它强调编写不依赖于特定数据类型的算法和数据结构，使得同一段代码能应用于多种数据类型，从而提高代码复用率和灵活性。例如，C++标准模板库(STL)中的容器类（如vector、list等）和算法（如sort、find等）都是泛型编程的应用实例。 模板元编程 , 模板元编程是C++中的一种高级技术，它利用模板系统在编译期间进行计算和逻辑推理，生成高效的运行时代码。模板元编程通常涉及模板递归、类型推导和模板特化等技术，能够在编译阶段确定并优化程序逻辑，尤其适用于那些需要在运行前就计算出结果或者构造复杂数据结构的情况。 C++概念（Concepts） , C++20引入的新特性，概念提供了一种在编译时验证模板参数是否满足特定要求的方法，增强了对模板类型约束的描述力和表达能力。通过定义和应用概念，开发人员可以更精确地控制模板的行为，并减少由于类型不匹配导致的编译错误，使得函数模板的使用更为安全且易于理解。

...在Go语言中，接口和类型转换是两个重要的概念。这些工具让我们能够随心所欲地构建灵活多变的程序架构，而且还能助我们一臂之力，更好地理解和掌握数据的各种小秘密。在这篇文章里，我打算掰开了揉碎了，把这两个概念给你讲得明明白白的，并且还会举出几个实实在在的例子，保准让你一听就豁然开朗，彻底整明白了。 第一章：什么是接口？ 在Go语言中，接口是一种特殊的类型，它只包含方法声明，而没有方法的实现。它的主要作用是用来描述一组对象的行为，而不是描述对象的具体实现。 例如，假设我们有一个名为Animal的接口，它定义了一个Speak()的方法： go type Animal interface { Speak() string } 这个接口告诉其他开发人员，如果一个对象实现了Speak()方法，那么它可以被认为是一个动物。 第二章：如何使用接口？ 我们可以使用接口来实现多态。这就意味着，哪怕我们手头的是不同类型的小玩意儿，但只要这些小玩意儿都乖乖实现了同一个约定（接口），那咱们就可以把它们视作同一挂的家伙来对待和处理，一点儿问题都没有。 例如，我们可以创建一个AnimalSpeaker的类型，它实现了Animal接口： go type AnimalSpeaker struct { animal Animal } func (as AnimalSpeaker) Speak() string { return as.animal.Speak() } 然后，我们可以使用AnimalSpeaker来处理任何实现了Animal接口的对象： go an := &Dog{} as := AnimalSpeaker{animal: an} fmt.Println(as.Speak()) // 输出 "Woof!" 在这个例子中，尽管an是一个Dog类型的对象，但因为它是Animal接口的实例，所以我们可以把它当作一个AnimalSpeaker来处理。 第三章：接口和类型转换 当我们需要在不同类型的对象之间进行转换时，我们通常会使用类型转换。在Go语言中，有两种类型转换：隐式转换和显式转换。 隐式转换是指Go语言自动进行的类型转换，例如，如果我们尝试将一个整型变量赋值给一个浮点型变量，Go语言会自动将其转换为浮点型。 显式转换是指我们需要手动进行的类型转换。在Go语言里头，如果你想进行一个明确的类型转换，可以采用这种写法：(T)(v)。这里边的T呢，就是你心里想的那个要转换成的目标类型；而v呢，则是你手头上那个打算拿来转换的原始值。这样说吧，就好比你想把一个水果（v）明确地变成一个苹果（T），你就得用上这个小技巧。 例如，如果我们有一个字符串"42"，我们想将其转换为整型，我们可以这样做： go s := "42" i, _ := strconv.Atoi(s) 在这个例子中，strconv.Atoi()函数就是一个显式转换的例子。它接受一个字符串作为参数，返回一个整型和一个错误。 总结： 在Go语言中，接口和类型转换是非常重要的概念。这些工具让我们能够构建超级灵活的程序架构，而且还帮我们更轻松地理解和搞定数据。通过理解这两种概念的工作原理，你可以写出更强大、更灵活的Go程序。

Scala中的类型安全的代码审查技巧 1. 引言 嗨，大家好！今天我想聊聊关于Scala编程语言中的类型安全问题。我得承认，刚开始接触Scala的时候，我对它的类型系统感到有点困惑。但是经过一段时间的学习和实践，我发现它真的非常强大。嘿，大家好！今天我想跟你们聊聊在代码审查时学到的一些小窍门，这样你就能写出更安全、更靠谱的Scala代码啦。 2. 了解类型系统的重要性 首先，我们来谈谈为什么类型安全如此重要。在实际开发中，类型错误往往是导致程序出错的一个重要原因。比如说，在Java里，你要是不小心把字符串当整数用了，编译器可能不吱声，但一运行程序就给你整出个异常来。在Scala里，类型系统可牛了，它能在你代码还没跑起来之前就找出那些潜在的坑，这样你就不用担心程序在运行时突然出幺蛾子了。 示例代码 scala // 错误示例 val x: Int = "hello" // 编译错误 这段代码会直接报错，因为类型不匹配。而在其他一些动态语言中，这可能会导致难以追踪的bug。 3. 利用泛型提升代码健壮性 接下来，我们要讨论的是泛型。泛型可是Scala类型系统里的一个大明星，用好了，你编的代码就能更灵活地对付各种数据类型，而且还能保证类型安全，妥妥的！ 示例代码 scala def printLength[T](list: List[T]): Unit = { println(list.length) } printLength(List(1, 2, 3)) // 正确 printLength(List("a", "b", "c")) // 正确 通过使用泛型，我们可以确保函数能够接受任何类型的列表，而不用担心类型错误。这种灵活性使得我们的代码更加健壮和可重用。 4. 使用case类进行模式匹配 在Scala中，case类是一个非常强大的工具，可以用来创建不可变的数据结构，并且支持模式匹配。利用case类，你可以写出更加清晰和安全的代码。 示例代码 scala sealed trait Result case class Success(value: Int) extends Result case class Failure(message: String) extends Result def processResult(result: Result): Unit = result match { case Success(value) => println(s"Success with value $value") case Failure(message) => println(s"Failure: $message") } processResult(Success(10)) // 输出：Success with value 10 processResult(Failure("Something went wrong")) // 输出：Failure: Something went wrong 在这个例子中，我们定义了一个密封特质Result及其两个子类Success和Failure。通过模式匹配，我们可以安全地处理不同类型的Result对象，而不用担心类型错误。 5. 重视类型别名 有时候，为了提高代码的可读性和可维护性，我们可能会给某些复杂的类型起一个新的名字。这就是类型别名的作用。通过类型别名，我们可以让代码更加简洁明了。 示例代码 scala type UserMap = Map[String, User] def getUserById(id: String)(users: UserMap): Option[User] = users.get(id) val users: UserMap = Map( "1" -> User("Alice"), "2" -> User("Bob") ) getUserById("1")(users) // 返回 Some(User("Alice")) 在这个例子中，我们为Map[String, User]定义了一个类型别名UserMap。这样一来，当我们声明变量或函数参数时，就可以用一个更易读的名字，而不用每次都打那串复杂的 Map[String, User] 了。 6. 结语 好了，今天的分享就到这里啦！希望这些关于Scala类型安全的技巧能对你有所帮助。记住，良好的编码习惯和对类型系统的深入理解，可以帮助我们写出更加健壮和可靠的代码。最后，编程之路漫漫，让我们一起继续探索吧！ --- 以上就是关于Scala中的类型安全的代码审查技巧的全部内容了。如果你有任何疑问或者想了解更多细节，欢迎随时留言交流。希望这篇分享对你有所帮助，也期待你在实际开发中能运用这些技巧写出更好的代码！

...MyBatis的数据类型映射 MyBatis是一款优秀的持久层框架，它为我们提供了数据访问的解决方案，大大简化了我们开发数据库操作的时间。在实际做项目的时候，我们常常会遇到这么个情况：得把Java对象和数据库里的表相互对应起来。这就是我们今天要讨论的主题——MyBatis的数据类型映射。 一、什么是数据类型映射？ 数据类型映射是指在Java对象和数据库之间的数据转换。简单来说，就像是这样：我们在Java代码里给对象定义的各种属性（也就是字段），可以理解为把它们“翻译”过去，对应到数据库表的各个列类型上。就好比你设计一个游戏人物时，给它设定的各种属性，比如力量、敏捷度，然后在数据库这个大表格里，找到对应的格子填上这些属性，只不过这里的“属性”换成了“列类型”。 二、如何配置数据类型映射？ 在MyBatis中，我们可以非常方便地进行数据类型映射。具体步骤如下： 1. 在mybatis-config.xml文件中配置全局映射 在mybatis-config.xml文件中，我们需要配置一个标签来指定一个特定的Java类型和数据库类型之间的映射。比如，如果我们手头有个Date类型的属性，我们或许会希望把它对应到数据库里的TIMESTAMP类型上。我们可以在mybatis-config.xml文件中这样配置： xml 这里，TypeHandler是自定义的一个接口，它有两个泛型参数，第一个参数是我们想要映射的Java类型，第二个参数是我们想要映射的数据库类型。 2. 自定义TypeHandler 接下来，我们需要创建一个实现了TypeHandler接口的类，并在这个类中重写write和read方法。这两个方法，各有各的神通，一个专门负责把Java对象里的内容神奇地变成数据库能理解并储存的值；另一个呢，则是反过来，能把数据库里躺着的数据，巧妙地转换成咱们Java世界里的对象。例如，我们可以创建如下的TypeHandler类： java public class DateToTimestampTypeHandler implements TypeHandler { @Override public void write(StringBuilder sql, Date date, BoundSql boundSql) { sql.append("TO_TIMESTAMP('").append(date).append("')"); } @Override public Date read(Class type, String source) { return new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(source); } } 在这里，我们首先调用了父类的write方法，然后在SQL语句中添加了一个函数TO_TIMESTAMP，这个函数可以将日期字符串转换为TIMESTAMP类型。而在read方法中，我们将数据库返回的字符串转换为了日期对象。 3. 在实体类中使用注解进行映射 除了全局映射之外，我们还可以在实体类中使用@Type注解来进行一对一的映射。例如，如果我们有一个User类，其中有一个Date类型的生日属性，我们可以这样使用@Type注解： java public class User { private String name; @Type(type = "com.example.mybatis.DateToTimestampTypeHandler") private Date birthday; // getters and setters... } 在这里，我们指定了birthday属性应该使用DateToTimestampTypeHandler进行映射。 三、总结 通过以上步骤，我们就可以在MyBatis中完成数据类型映射了。这个功能简直不要太重要，它简直就是我们提升开发效率、减少无谓错误的小帮手，最关键的是，它还能让我们的代码变得更加简洁明了，读起来就像看小说一样轻松愉快！所以，希望大家能够熟练掌握并使用这个功能。

...lin：一场关于无效参数的冒险 引子：一次突如其来的挑战 在编程的世界里，Kotlin以其简洁明了的语法、强大的类型安全机制以及对Java语言的兼容性，赢得了无数开发者的心。哎呀，兄弟，你这语言用得确实牛批，但就像开车一样，再溜的车也难免会碰上坑坑洼洼。在这堆问题里头，有一种特别让人头疼的家伙，叫 IllegalArgumentException。这家伙就像是突然冒出来的路障，让你措手不及，一不小心就踩中了，结果就是程序卡壳，半天解不开。这不就是我们在编程路上的“小麻烦”嘛！今天，我们就来一起探索一下这个“非法参数异常”背后的故事。 第一章：何为 IllegalArgumentException 在Kotlin中，当我们尝试调用一个方法时，如果传入的参数不符合该方法的要求或者类型不匹配，就会抛出 IllegalArgumentException。这事儿就像你去参加一个超级认真的补习班，老师布置了一道题目让你做，结果你交上去的答案全错了，那肯定得被老师好好点名批评一番了。 第二章：深入剖析 IllegalArgumentException 假设我们有一个简单的函数 calculateAge，它接受一个人的出生年份作为参数，并计算出当前年龄： kotlin fun calculateAge(birthYear: Int): Int { val currentYear = 2023 return currentYear - birthYear } 如果我们不小心传入了一个非整数类型的参数，比如一个字符串，Kotlin会立即察觉到这一点，并优雅地抛出 IllegalArgumentException： kotlin fun test() { val age = calculateAge("2000") println("Your age is $age.") } // 运行结果：编译错误，因为calculateAge接受的是Int类型参数，而"2000"是String类型。 第三章：如何避免 IllegalArgumentException 避免 IllegalArgumentException 的关键在于确保所有传入函数的参数都符合预期的类型和格式。我们可以利用Kotlin的静态类型系统来帮助我们进行这一工作： - 类型检查：确保所有输入的参数都是正确的类型。例如，可以使用 assert 函数在运行时验证类型： kotlin fun safeCalculateAge(birthYear: Any): Int { assert(birthYear is Int) { "Expected an Integer for birthYear" } val currentYear = 2023 return currentYear - birthYear.toInt() } // 使用示例： val age = safeCalculateAge(2000) println("Your age is $age.") - 函数参数验证：在定义函数时就加入类型检查逻辑： kotlin fun calculateAgeWithValidation(birthYear: Int): Int { if (birthYear < 0 || birthYear > 2023) { throw IllegalArgumentException("Birth year must be within the range of 0 to 2023.") } val currentYear = 2023 return currentYear - birthYear } 第四章：实战演练：创建一个更复杂的示例 假设我们要构建一个简单的日历应用，其中包含一个用于计算天数的函数。为了增加复杂性，我们添加了对月份和年份的验证： kotlin data class Date(val day: Int, val month: Int, val year: Int) fun calculateDaysSinceBirthday(dateOfBirth: Date): Int { val currentYear = Calendar.getInstance().get(Calendar.YEAR) val currentMonth = Calendar.getInstance().get(Calendar.MONTH) + 1 // 注意月份是从0开始的 val currentDay = Calendar.getInstance().get(Calendar.DAY_OF_MONTH) val birthday = dateOfBirth.day to dateOfBirth.month to dateOfBirth.year val birthDate = Date(birthday) val daysSinceBirthday = (currentYear - birthDate.year) 365 + (currentMonth - birthDate.month) 30 + (currentDay - birthDate.day) return daysSinceBirthday } fun main() { val birthDate = Date(day = 1, month = 1, year = 2000) val days = calculateDaysSinceBirthday(birthDate) println("Days since your birthday: $days") } 在上面的代码中，我们通过 Calendar 类获取当前日期，并与生日日期进行比较，计算出天数差值。嘿，兄弟！咱们就拿一年有365天，一个月有30天来打个比方，这可是咱们简化了一下，方便大家理解。实际上啊，生活里头可没这么简单，得分清闰年和普通年是怎么回事，这样日子才过得有模有样呢！ 结语：面对挑战，拥抱学习 每一次遇到 IllegalArgumentException 都是一次学习的机会。它们提醒我们，即使在看似完美的代码中，也可能隐藏着一些小错误。通过仔细检查和验证我们的参数，我们可以编写出更加健壮、可维护的代码。哎呀，你瞧这Kotlin，它可真是个能手呢！它那一大堆好用的工具和特性，就像是魔法一样，帮我们解决了好多麻烦事儿。比如说，静态类型这一招，就像是一道坚固的防线，能提前发现那些可能出错的地方。还有函数注解，就像是给代码贴上了标签，让我们一眼就能看出这是干啥的。而模式匹配嘛，简直就是解谜神器，轻轻松松就能解开那些复杂的逻辑难题。这些玩意儿合在一起，就形成了一个强大的武器库，帮我们防患于未然，解决问题更是不在话下。你说是不是，这Kotlin，简直就是程序员的好伙伴！让我们带着好奇心和探索精神，继续在编程的海洋中航行吧！ --- 在这篇文章中，我们不仅探讨了 IllegalArgumentException 的由来和解决方法，还通过一系列的代码示例展示了如何在实践中应用这些知识。嘿，兄弟！读完这篇文章后，希望你对Kotlin里的异常处理方式有了一番全新的领悟。别担心，这不像是AI在跟你说话，就像跟老朋友聊天一样轻松。你得尝试将这些小技巧应用到你的实际项目中，让代码不仅好看，而且超级稳定，就像是给你的程序穿上了一件坚固的盔甲。这样，无论遇到什么问题，它都能稳如泰山。所以，拿起你的键盘，动手实践吧！记住，编程是一场持续的学习之旅，每一次遇到困难都是成长的机会。加油！