多线程设计模式系列 -java.docx
文本预览下载声明
第一章,java语言的线程单线程程序:打印10000次good字符串public class SingleThreadSample { public static void main(String[] args) { for(int i=0; i 10000; i++){ System.out.print(good!); } }}严格的说并不是只有一个线程在操作,还有其他的线程在非java处理系统上运行,比如gc,gui相关的线程等。 第一个多线程程序:实现了交替打印good和nice的功能public class MyThreadTest { public static void main(String[] args) { MyThread t = new MyThread(); t.start(); for (int i = 0; i 10000; i++) { System.out.println(good!); } }} class MyThread extends Thread { @Override public void run() { for (int i = 0; i 10000; i++) { System.out.println(nice!); } }} 这里加入一个并发和并行概念的区别,并发是concurrent,是指多个线程在同一个cpu上切换进行执行。并行是parallel,指多个线程是在各自的cpu上同时执行的。我们增强一下刚才的多线程例子,把打印的字符串变成通过参数传递。public class MyThread2Test { public static void main(String[] args) { MyThread2 t1 = new MyThread2(good!); MyThread2 t2 = new MyThread2(nice!); t1.start(); t2.start(); } } class MyThread2 extends Thread { private String message; public MyThread2(String message) { this.message = message; } @Override public void run() { for (int i = 0; i 10000; i++) { System.out.println(message); } }} 刚才是通过集成Thread抽象类的子类方式实现多线程,另外还可以通过Runnable接口的方式,例子如下:public class MyThread3Test { public static void main(String[] args) { MyThread3 t1 = new MyThread3(good!); MyThread3 t2 = new MyThread3(nice!); new Thread(t1).start(); new Thread(t2).start(); }} class MyThread3 implements Runnable { private String message; public MyThread3(String message) { this.message = message; } @Override public void run() { for (int i = 0; i 10000; i++) { System.out.println(message); } }} 启动和执行多线程已经说完了,那么该说说如何让线程休息休息。第一种方式是通过Thread.sleep(ms)方法,需要注意的是这个方法有一个重载Thread.sleep(ms,ns),可以把停止的时间控制到纳秒级。另外Thread.yield()方法也可以在循环体中使用,表示如果没有cpu时间则将当前线程切换到其他子线程,可以简单理解成Thread.sleep(0); 不过Thread.sleep会抛出InterruptedException异常,Thread.yield不会。 下面在说说线程互斥,还是刚才的例子,如果我打算让程序执行10000次打印的过程是一个整体,执行过程中不允许切换到其他子线程,那么就需要使用Synchronzed关键字。public class MyThreadMutualTest { public static void main(String[] args) { PrintMessage pmsg = new PrintMessage(); new MyThreadMutual(pmsg,good).s
显示全部