@yexiaoqi
2018-12-04T02:14:39.000000Z
字数 3160
阅读 1152
java面试总结
答:多核CPU下资源利用率高,效率高
Thread类,重写run方法。创建本类对象,调用start( )开启线程Runable接口,重写run方法。创建Thread类对象,传递本类对象,调用start( )开启线程Callable接口,重写call方法,需要依赖于线程池执行。NEW:至今尚未启动的线程处于这种状态。RUNNABLE:正在Java虚拟机中执行的线程处于这种状态。BLOCKED:受阻塞并等待某个监视器锁的线程处于这种状态。WAITING:无限期地等待另一个线程来执行某一特定操作的线程处于这种状态。TIMED_WAITING:等待另一个线程来执行取决于指定等待时间操作的线程处于这种状态。TERMINATED:已退出的线程处于这种状态。ExecutorService(接口)表示线程池,实现类ThreadPoolExecutor。此类的某个构造方法有7个参数,分别是: corePoolSize - 池中所保存的线程数,包括空闲线程数。maximumPoolSize - 池中允许的最大线程数。keepAliveTime - 单线程数大于核心时,此为终止前多余的空闲线程等待新任务的最长时间。unit - keepAliveTime参数的时间单位workQueue - 执行前用于保持任务的队列。此队列仅保持由execute方法提交的Runnable 任务。threadFactory - 执行程序创建新线程时使用的工厂。handler - 由于超出线程范围和队列容量而使执行被阻断时所使用的处理程序。newCachedThreadPool():带缓存功能的线程池newFixedThreadPool(int nThreads):可以指定固定个数的线程池newScheduledThreadPool(int corePoolSize):支持定时和周期性执行任务的线程池。newSingleThreadExecutor():只有一个线程的线程池,内部维护一个任务队列,依次执行Semaphore:信号量,允许同一时间有指定个数的线程执行同一任务CountDownLatch:用来协调多个线程之间的同步。能够使一个线程在等待另外一些线程完成各自的工作之后,再继续执行,使用一个计数器实现。CyclicBarrier:它要做的事是让一组线程到达一个屏障(同步点)时被阻塞,知道最后一个线程到达屏障时,屏障才会开门,所有被屏障拦截的线程才会继续工作。
public class DeadLock {String resource1 = "资源1";String resource2 = "资源2";Thread t1 = new Thread("线程1"){public void run() {while (true){synchronized (resource1){try {Thread.sleep(500);} catch (InterruptedException e) {e.printStackTrace();}synchronized (resource2){System.out.println("线程1拥有"+resource1+",需要"+resource2);}}}}};Thread t2 = new Thread("线程2"){public void run() {while (true){synchronized (resource2){try {Thread.sleep(500);} catch (InterruptedException e) {e.printStackTrace();}synchronized (resource1){System.out.println("线程2拥有"+resource2+",需要"+resource1);}}}}};public static void main(String a[]){DeadLock test = new DeadLock();test.t1.start();test.t2.start();}}
死锁了如何解决?思路?
使用Callable+FutureTask获取执行结果的例子
public class Test {public static void main(String[] args) {//第一种方式ExecutorService executor = Executors.newCachedThreadPool();Task task = new Task();//用任务对象构造一个FutureTask对象FutureTask<Integer> futureTask = new FutureTask<Integer>(task);//直接把FutureTask对象提交给线程池,让去执行executor.submit(futureTask);executor.shutdown();//第二种方式,注意这种方式和第一种方式效果是类似的,只不过一个使用的是ExecutorService,一个使用的是Thread/*Task task = new Task();FutureTask<Integer> futureTask = new FutureTask<Integer>(task);//通过FutureTask对象构造一个线程对象Thread thread = new Thread(futureTask);thread.start();*/try {Thread.sleep(1000);} catch (InterruptedException e1) {e1.printStackTrace();}System.out.println("主线程在执行任务");try {//执行完后,futureTask.get()获取线程执行结果System.out.println("task运行结果"+futureTask.get());} catch (InterruptedException e) {e.printStackTrace();} catch (ExecutionException e) {e.printStackTrace();}System.out.println("所有任务执行完毕");}}class Task implements Callable<Integer>{@Overridepublic Integer call() throws Exception {System.out.println("子线程在进行计算");Thread.sleep(3000);int sum = 0;for(int i=0;i<100;i++)sum += i;return sum;}}
boolean cancel(boolean mayInterruptInRunning) 取消一个任务,并返回取消结果。参数表示是否中断线程。
boolean isCancelled() 判断任务是否被取消
Boolean isDone() 判断当前任务是否执行完毕,包括正常执行完毕、执行异常或者任务取消。
V get() 获取任务执行结果,任务结束之前会阻塞。
V get(long timeout, TimeUnit unit) 在指定时间内尝试获取执行结果。若超时则抛出超时异常