package timer;import java.util.Calendar;
import java.util.Timer;
import java.util.TimerTask;public class TimerTest {static Timer timer = new Timer();public static void main(String[] args) {// task task to be scheduled.// delay delay in milliseconds before task is to be executed.// period time in milliseconds between successive task executions.timer.schedule(new MyTimerTask(), 2000);}}
/** 执行间隔2秒与4秒交替进行*/
class MyTimerTask extends TimerTask {static boolean change = true;Calendar calendar = Calendar.getInstance();@Overridepublic void run() {change = !change;System.out.println(calendar.getTime());new Timer().schedule(new MyTimerTask(), change ? 2000 : 4000);}}

package Thread;/*** 子线程2次，主线程4次交替循环10次。**/
public class AlternateLoop {static Sysout sysout = new Sysout();public static void main(String[] args) {for (int i = 0; i < 10; i++) {sysout.subBusiness(i);sysout.mainBusiness(i);}}}// class MyThread implements Runnable {
// @Override
// public void run() {
// AlternateLoop.sysout.subBusiness(1);
// }
// }
//
// class MyThread2 implements Runnable {
//
// @Override
// public void run() {
// AlternateLoop.sysout.mainBusiness(i);
// }
// }/** 同一资源管理业务逻辑*/
class Sysout {private boolean isSub = true;public synchronized void mainBusiness(int i) {while (isSub) {try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}}for (int j = 0; j < 4; j++) {System.out.println("mainBusiness" +j+"loop of"+ i);}isSub = true;this.notify();}public synchronized void subBusiness(int i) {while (!isSub) {try {this.wait();} catch (InterruptedException e) {e.printStackTrace();}}for (int j = 0; j < 2; j++) {System.out.println("subBusiness" +j+"loop of"+ i);}isSub = false;this.notify();}
}

package Thread;import java.util.Random;public class ThreadLocalTest {public static ThreadLocal<Integer> threadLocal = new ThreadLocal<Integer>();public static void main(String[] args) {for (int i = 0; i < 2; i++) {new Thread(new Runnable() {@Overridepublic void run() {int data=new Random().nextInt();System.out.println(Thread.currentThread().getName()+"has put data :"+data);threadLocal.set(data);new A().get();new B().get();}}).start();}}static class A {public void get() {int data=threadLocal.get();System.out.println("A from Thread" + Thread.currentThread().getName() + ""+ data);}}static class B {public void get() {int data=threadLocal.get();System.out.println("B from Thread" + Thread.currentThread().getName() + ""+ data);}}
}

package Thread;import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;public class ThreadPoolTest {public static void main(String[] args) {ExecutorService threadPool =Executors.newCachedThreadPool();
//        ExecutorService threadPool =Executors.newFixedThreadPool(10);
//        ExecutorService threadPool = Executors.newSingleThreadExecutor();for (int i = 0; i < 10; i++) {final int task = 1;threadPool.execute(new Runnable() {@Overridepublic void run() {for (int j = 0; j < 10; j++) {try {Thread.sleep(200);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(Thread.currentThread().getName()+ "is looping of " + j + "for task of" + task);}}});}Executors.newScheduledThreadPool(3).scheduleAtFixedRate(new Runnable() {@Overridepublic void run() {System.out.println("bombing!");}}, 6, 2, TimeUnit.SECONDS);}
}