HashMap 是一个散列表,它存储的内容是键值对(key-value)映射。java
HashMap 继承于AbstractMap,实现了Map、Cloneable、java.io.Serializable接口。面试
HashMap 的实现不是同步的,这意味着它不是线程安全的。它的key、value均可觉得null。此外,HashMap中的映射不是有序的。算法
HashMap 的实例有两个参数影响其性能:“初始容量” 和 “加载因子”。容量 是哈希表中桶的数量,初始容量 只是哈希表在建立时的容量。加载因子 是哈希表在其容量自动增长以前能够达到多满的一种尺度。当哈希表中的条目数超出了加载因子与当前容量的乘积时,则要对该哈希表进行 rehash 操做(即重建内部数据结构),从而哈希表将具备大约两倍的桶数。数据库
继承关系数组
hashmap底层就是一个数组,而后数组里每一个元素装了个链表。缓存
这个数组元素称为bucket桶安全
图例数据结构
HashTable和HashMap区别多线程
第一,继承不一样。架构
Java
1 2 |
public class Hashtable extends Dictionary implements Map public class HashMap extends AbstractMap implements Map |
第二,Hashtable 中的方法是同步的,而HashMap中的方法在缺省状况下是非同步的。在多线程并发的环境下,能够直接使用Hashtable,可是要使用HashMap的话就要本身增长同步处理了,对HashMap的同步处理可使用Collections类提供的synchronizedMap静态方法,或者直接使用JDK 5.0以后提供的java.util.concurrent包里的ConcurrentHashMap类。
第三,Hashtable中,key和value都不容许出现null值。在HashMap中,null能够做为键,这样的键只有一个;能够有一个或多个键所对应的值为null。当get()方法返回null值时,便可以表示 HashMap中没有该键,也能够表示该键所对应的值为null。所以,在HashMap中不能由get()方法来判断HashMap中是否存在某个键,而应该用containsKey()方法来判断。
第四,两个遍历方式的内部实现上不一样。
Hashtable、HashMap都使用了 Iterator。而因为历史缘由,Hashtable还使用了Enumeration的方式 。
第五,哈希值的使用不一样,HashTable直接使用对象的hashCode。而HashMap从新计算hash值( indexFor )。
第六,Hashtable和HashMap它们两个内部实现方式的数组的初始大小和扩容的方式。HashTable中hash数组默认大小是11,增长的方式是 old*2+1。HashMap中hash数组的默认大小是16,并且必定是2的指数。
Java
1 2 3 |
public enum Singleton{ INSTANCE; } |
在序列化的时候Java仅仅是将枚举对象的name属性输出到结果中,反序列化的时候则是经过java.lang.Enum的valueOf方法来根据名字查找枚举对象。
内存模型架构图
每一个线程有要有一个独立的程序计数器,记录下一条要运行的指令。线程私有的内存区域。若是执行的是JAVA方法,计数器记录正在执行的java字节码地址,若是执行的是native方法,则计数器为空。
线程私有的,与线程在同一时间建立。管理JAVA方法执行的内存模型。
和虚拟机栈功能类似,但管理的不是JAVA方法,是本地方法
线程共享的,用于存放被虚拟机加载的类的元数据信息:如常量、静态变量、即时编译器编译后的代码。也称为永久代。
线程共享的,存放全部对象实例和数组。垃圾回收的主要区域。能够分为新生代和老年代(tenured)。
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 |
package cn.gaialine.threadpool;
import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.ThreadPoolExecutor.AbortPolicy; import java.util.concurrent.TimeUnit;
/** * 线程池测试用例 * @author yangyong * */ public class TestThreadPool { //线程池维护线程的最少数量 private static final int COREPOOLSIZE = 2; //线程池维护线程的最大数量 private static final int MAXINUMPOOLSIZE = 5; //线程池维护线程所容许的空闲时间 private static final long KEEPALIVETIME = 4; //线程池维护线程所容许的空闲时间的单位 private static final TimeUnit UNIT = TimeUnit.SECONDS; //线程池所使用的缓冲队列,这里队列大小为3 private static final BlockingQueue<Runnable> WORKQUEUE = new ArrayBlockingQueue<Runnable>(3); //线程池对拒绝任务的处理策略:AbortPolicy为抛出异常;CallerRunsPolicy为重试添加当前的任务,他会自动重复调用execute()方法;DiscardOldestPolicy为抛弃旧的任务,DiscardPolicy为抛弃当前的任务 private static final AbortPolicy HANDLER = new ThreadPoolExecutor.AbortPolicy();
public static void main(String[] args) { // TODO 初始化线程池 ThreadPoolExecutor threadPool = new ThreadPoolExecutor(COREPOOLSIZE, MAXINUMPOOLSIZE, KEEPALIVETIME, UNIT, WORKQUEUE, HANDLER); for (int i = 1; i < 11; i++) { String task = "task@"+i; System.out.println("put->"+task); //一个任务经过 execute(Runnable)方法被添加到线程池,任务就是一个 Runnable类型的对象,任务的执行方法就是 Runnable类型对象的run()方法 //处理任务的优先级为:核心线程corePoolSize、任务队列workQueue、最大线程maximumPoolSize,若是三者都满了,使用handler处理被拒绝的任务 //设此时线程池中的数量为currentPoolSize,若currentPoolSize>corePoolSize,则建立新的线程执行被添加的任务, //当corePoolSize+workQueue>currentPoolSize>=corePoolSize,新增任务被放入缓冲队列, //当maximumPoolSize>currentPoolSize>=corePoolSize+workQueue,建新线程来处理被添加的任务, //当currentPoolSize>=maximumPoolSize,经过 handler所指定的策略来处理新添加的任务 //本例中能够同时能够被处理的任务最多为maximumPoolSize+WORKQUEUE=8个,其中最多5个在线程中正在处理,3个在缓冲队列中等待被处理 //当currentPoolSize>corePoolSize时,若是某线程空闲时间超过keepAliveTime,线程将被终止。这样,线程池能够动态的调整池中的线程数 threadPool.execute(new ThreadPoolTask(task)); try { Thread.sleep(1000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } threadPool.shutdown();//关闭主线程,但线程池会继续运行,直到全部任务执行完才会中止。若不调用该方法线程池会一直保持下去,以便随时添加新的任务 } } |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 |
package cn.gaialine.threadpool;
import java.io.Serializable;
/** * 任务task * @author yangyong * */ public class ThreadPoolTask implements Runnable,Serializable{ private static final long serialVersionUID = -8568367025140842876L;
private Object threadPoolTaskData; private static int produceTaskSleepTime = 10000;
public ThreadPoolTask(Object threadPoolTaskData) { super(); this.threadPoolTaskData = threadPoolTaskData; }
public void run() { // TODO Auto-generated method stub System.out.println("start..."+threadPoolTaskData); try { //模拟线程正在执行任务 Thread.sleep(produceTaskSleepTime); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } System.out.println("stop..."+threadPoolTaskData); threadPoolTaskData = null; }
public Object getTask(){ return this.threadPoolTaskData; } //--------------- put->task@1 start...task@1 put->task@2 start...task@2 put->task@3 put->task@4 put->task@5 put->task@6 start...task@6 put->task@7 start...task@7 put->task@8 start...task@8 put->task@9 Exception in thread "main" java.util.concurrent.RejectedExecutionException at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(Unknown Source) at java.util.concurrent.ThreadPoolExecutor.reject(Unknown Source) at java.util.concurrent.ThreadPoolExecutor.execute(Unknown Source) at cn.gaialine.threadpool.TestThreadPool.main(TestThreadPool.java:42) stop...task@1 start...task@3 stop...task@2 start...task@4 stop...task@6 start...task@5 stop...task@7 stop...task@8 stop...task@3 stop...task@4 stop...task@5 |
从中能够看出task1和task2依次最早执行,这时候currentPoolSize=2达到了corePoolSize,task三、task四、task5被送入缓冲队列,达到了workQueue最大值3,task六、task七、task8开启新的线程开始执行,此时currentPoolSize=5达到了maximumPoolSize,task九、task10根据AbortPolicy策略抛出异常,再也不执行task9和task10。10秒钟后task一、task2….依次执行完毕释放线程,开始执行队列里的task三、task四、task5,最后task三、四、5执行完毕,全部任务完成。
JDK根据ThreadPoolExecutor配置好的线程池
1 2 3 4 5 6 7 8 9 10 11 |
// 固定工做线程数量的线程池 ExecutorService executorService1 = Executors.newFixedThreadPool(3);
// 一个可缓存的线程池 ExecutorService executorService2 = Executors.newCachedThreadPool();
// 单线程化的Executor ExecutorService executorService3 = Executors.newSingleThreadExecutor();
// 支持定时的以及周期性的任务执行 ExecutorService executorService4 = Executors.newScheduledThreadPool(3); |
内存模型描述了程序中各个变量(实例域、静态域和数组元素)之间的关系,以及在实际计算机系统中将变量存储到内存和从内存中取出变量这样的底层细节。
JVM中存在一个主存区(Main Memory或Java Heap Memory),Java中全部变量都是存在主存中的,对于全部线程进行共享,而每一个线程又存在本身的工做内存(Working Memory),工做内存中保存的是主存中某些变量的拷贝,线程对全部变量的操做并不是发生在主存区,而是发生在工做内存中,而线程之间是不能直接相互访问,变量在程序中的传递,是依赖主存来完成的。
JMM的最初目的,就是为了可以支持多线程程序设计的,每一个线程能够认为是和其余线程不一样的CPU上运行,或者对于多处理器的机器而言,该模型须要实现的就是使得每个线程就像运行在不一样的机器、不一样的CPU或者自己就不一样的线程上同样。
在Java中,为了保证多线程读写数据时保证数据的一致性,能够采用两种方式:
如用synchronized关键字,或者使用锁对象.
使用volatile关键字
用一句话归纳volatile,它可以使变量在值发生改变时能尽快地让其余线程知道.
volatile本质是在告诉jvm当前变量在寄存器中的值是不肯定的,须要从主存中读取,synchronized则是锁定当前变量,只有当前线程能够访问该变量,其余线程被阻塞住.
volatile仅能使用在变量级别,synchronized则可使用在变量,方法.
volatile仅能实现变量的修改可见性,但不具有原子特性,而synchronized则能够保证变量的修改可见性和原子性.
volatile不会形成线程的阻塞,而synchronized可能会形成线程的阻塞.
volatile标记的变量不会被编译器优化,而synchronized标记的变量能够被编译器优化.
由于时间有限,没有多想,直接使用冒泡排序冒一半的数据,另外一半保持无序。若是有更好的方法请告诉我谢谢!
使用case when就能够实现了,可是要注意须要对每一个case when作max,以及最后的group by,这样能够去除null值。
一时间没想明白,由于以为不会有人写成hashmap = new hashmap,就答了一下实现依赖抽象,方便复用和修改,减小栈存储之类乱七八糟的东西。。。若是有更好的答案也请告诉我谢谢😢
Object类中的equals方法和“==”是同样的,没有区别,而String类,Integer类等等一些类,是重写了equals方法,才使得equals和“==不一样”,因此,当本身建立类时,自动继承了Object的equals方法,要想实现不一样的等于比较,必须重写equals方法。
“==”比”equal”运行速度快,由于”==”只是比较引用.
这真是个高频问题,从大四找实习面试到研究生找工做面试到两次跳槽一共几十场技术面试几乎全都问到了。惟一一次没问到的一次是由于我面的是算法工程师的职位,那次都在面机器学习的算法和实现……
默认 equals 方法直接调用了 ==
1 2 3 |
public boolean equals(Object obj) { return (this == obj); } |
String 改写了 equals
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 |
public boolean equals(Object anObject) { if (this == anObject) { return true; } if (anObject instanceof String) { String anotherString = (String) anObject; int n = value.length; if (n == anotherString.value.length) { char v1[] = value; char v2[] = anotherString.value; int i = 0; while (n-- != 0) { if (v1[i] != v2[i]) return false; i++; } return true; } } return false; } |
hashCode是根类Obeject中的方法。默认状况下,Object中的hashCode() 返回对象的32位jvm内存地址。也就是说若是对象不重写该方法,则返回相应对象的32为JVM内存地址。
String类源码中重写的hashCode方法以下:
1 2 3 4 5 6 7 8 9 10 11 12 |
public int hashCode() { int h = hash; //Default to 0 ### String类中的私有变量, if (h == 0 && value.length > 0) { //private final char value[]; ### Sting类中保存的字符串内容的的数组 char val[] = value;
for (int i = 0; i < value.length; i++) { h = 31 * h + val[i]; } hash = h; } return h; } |
(1)绑定。当equals方法被重写时,一般有必要重写 hashCode 方法,以维护 hashCode 方法的常规协定,该协定声明相等对象必须具备相等的哈希码。
(2)绑定缘由。Hashtable实现一个哈希表,为了成功地在哈希表中存储和检索对象,用做键的对象必须实现 hashCode 方法和 equals 方法。同(1),必须保证equals相等的对象,hashCode 也相等。由于哈希表经过hashCode检索对象。
(3)默认。
==默认比较对象在JVM中的地址。
hashCode 默认返回对象在JVM中的存储地址。
equal比较对象,默认也是比较对象在JVM中的地址,同==