第一章线程管理

一时失言乱红尘 2024-02-18 14:47 119阅读 0赞

### 第一章线程管理 ###

#### 1.1、同步、异步 ####

同步：多个线程一个一个执行

异步：多个线程一起抢着执行

#### 1.2、线程的创建和运行 ####

创建线程的方式：

1、继承Thread类，并且覆盖run()方法

2、实现Runnable接口的类。使用带参数的Thread构造器来创建Thread对象。这个参数就是Runnable接口的一个实现对象

示例：

#### 1.3、线程信息的获取和设置 ####

ID：线程的唯一标识符

Name：线程名称

Priority：线程的优先级，1~10之间，数值越高优先级越高。

Status：线程的状态。线程有6种状态：new、runnable、blocked、waiting、time waiting、terminated

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> public class Calculator implements Runnable { &nbsp; &nbsp;&nbsp;&nbsp; private int number; &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; public Calculator(int number) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.number=number; &nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp; public void run() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.printf("%s:&nbsp; %d\n",Thread.currentThread().getName(),number,number); &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; &nbsp; public class Main { &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread threads[] = new Thread[10]; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (int i=0; i&lt;10; i++){ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; threads[i]=new Thread(new Calculator(i)); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if ((i%2)==0){ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; threads[i].setPriority(Thread.MAX_PRIORITY); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } else { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; threads[i].setPriority(Thread.MIN_PRIORITY); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; threads[i].setName("Thread "+i); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (Thread thread : threads) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("Thread-ID:" + thread.getId() + " Thread-Name:"+thread.getName() + " Thread Status:"+thread.getState()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("--------------------------------------------------------------------------"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (Thread thread : threads) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; thread.start(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("Thread-ID:" + thread.getId() + " Thread-Name:"+thread.getName() + " Thread Status:"+thread.getState()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } </td> 
 </tr> 
 </tbody> 
</table>

#### 1.4、线程的中断 ####

#### 1.5、线程中断的控制 ####

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> 程序分析：以下程序主要是通过throw new InterruptedException();控制被run调用的方法，来终止被调用方法的继续执行，并非是终止线程！！！ &nbsp; </td> 
 </tr> 
 <tr> 
 <td style="border-color:#000000;vertical-align:top;width:426.1pt;"> &nbsp; public class FileSearch implements Runnable { &nbsp; &nbsp;&nbsp;&nbsp; private String initPath; &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; private String fileName; &nbsp; &nbsp;&nbsp;&nbsp; public FileSearch(String initPath, String fileName) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.initPath = initPath; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.fileName = fileName; &nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp; public void run() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; File file = new File(initPath); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (file.isDirectory()) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; directoryProcess(file); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (InterruptedException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.printf("%s: The search has been interrupted",Thread.currentThread().getName()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; cleanResources(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp; private void cleanResources() { &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp; private void directoryProcess(File file) throws InterruptedException { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; File list[] = file.listFiles(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (list != null) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (int i = 0; i &lt; list.length; i++) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (list[i].isDirectory()) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; directoryProcess(list[i]); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } else { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; fileProcess(list[i]); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (Thread.interrupted()) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; throw new InterruptedException(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp; private void fileProcess(File file) throws InterruptedException { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (file.getName().equals(fileName)) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.printf("%s : %s\n",Thread.currentThread().getName() ,file.getAbsolutePath()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (Thread.interrupted()) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; throw new InterruptedException(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; &nbsp; &nbsp; &nbsp; public class Main { &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; FileSearch searcher=new FileSearch("C:\\","autoexec.bat"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread thread=new Thread(searcher); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; thread.start(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; TimeUnit.SECONDS.sleep(10); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (InterruptedException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; thread.interrupt(); &nbsp;&nbsp;&nbsp; } &nbsp; } </td> 
 </tr> 
 </tbody> 
</table>

#### 1.6、线程的休眠和恢复 ####

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> 以下程序通过interrupt()方法来打断sleep休眠 Sleep是让程序挂起休眠 </td> 
 </tr> 
 <tr> 
 <td style="border-color:#000000;vertical-align:top;width:426.1pt;"> public class FileClock implements Runnable { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp;&nbsp; public void run() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (int i = 0; i &lt; 10; i++) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.printf("%s\n", new Date()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; TimeUnit.SECONDS.sleep(1); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (InterruptedException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("The FileClock has been interrupted"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp; } } &nbsp; public class Main { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp; public static void main(String[] args) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; FileClock clock=new FileClock(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread thread=new Thread(clock); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; thread.start(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; TimeUnit.SECONDS.sleep(5); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (InterruptedException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; thread.interrupt(); &nbsp;&nbsp;&nbsp;&nbsp; } } </td> 
 </tr> 
 </tbody> 
</table>

#### 1.7、等待线程的终止 ####

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> thread.Join把指定的线程加入到当前线程，可以将两个交替执行的线程合并为顺序执行的线程。 也就是说，下面的线程会等待上面的线程执行结束再去执行 </td> 
 </tr> 
 <tr> 
 <td style="border-color:#000000;vertical-align:top;width:426.1pt;"> &nbsp; class RunnableJob implements Runnable { &nbsp; &nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp; public void run() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread thread = Thread.currentThread(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread.sleep(1000); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println(thread.getName() + " end" + " at "&nbsp; + new Date()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (InterruptedException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; public class BasicTest { &nbsp;&nbsp;&nbsp; public static void main(String[] args) throws InterruptedException { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //初始化 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; RunnableJob runnableJob = new RunnableJob(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread T1 = new Thread(runnableJob, "T1"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread T2 = new Thread(runnableJob, "T2"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread T3 = new Thread(runnableJob, "T3"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //T2在T1执行完后执行，T3在T2执行完后执行 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; T1.start(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; T1.join(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; T2.start(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; T2.join(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; T3.start(); &nbsp;&nbsp;&nbsp; } &nbsp; } </td> 
 </tr> 
 </tbody> 
</table>

#### 1.8、守护线程的创建和运行 ####

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> 守护线程适合做监控等后台操作 </td> 
 </tr> 
 <tr> 
 <td style="border-color:#000000;vertical-align:top;width:426.1pt;"> public class Event { &nbsp; &nbsp;&nbsp;&nbsp; private Date date; &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; private String event; &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; public Date getDate() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return date; &nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; public void setDate(Date date) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.date = date; &nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; public String getEvent() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return event; &nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; public void setEvent(String event) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.event = event; &nbsp;&nbsp;&nbsp; } } &nbsp; &nbsp; public class WriterTask implements Runnable { &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; Deque&lt;Event&gt; deque; &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; public WriterTask (Deque&lt;Event&gt; deque){ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.deque=deque; &nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp; public void run() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (int i=1; i&lt;100; i++) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Event event=new Event(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; event.setDate(new Date()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; event.setEvent("线程="+Thread.currentThread().getId()+"被创建"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; deque.addFirst(event); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; TimeUnit.SECONDS.sleep(1); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (InterruptedException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; } } &nbsp; &nbsp; &nbsp; &nbsp; public class CleanerTask extends Thread { &nbsp; &nbsp;&nbsp;&nbsp; private Deque&lt;Event&gt; deque; &nbsp; &nbsp;&nbsp;&nbsp; public CleanerTask(Deque&lt;Event&gt; deque) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.deque = deque; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; setDaemon(true); &nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp; public void run() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; while (true) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Date date = new Date(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; clean(date); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp; private void clean(Date date) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; long difference; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean delete; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (deque.size()==0) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; delete=false; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; do { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Event e = deque.getLast(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; difference = date.getTime() - e.getDate().getTime(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (difference &gt; 10000) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("清除事件: "+e.getEvent()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; deque.removeLast(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; delete=true; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } while (difference &gt; 10000); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (delete){ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("清除后队列大小:"+deque.size()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; } } &nbsp; &nbsp; &nbsp; &nbsp; public class Main { &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Deque&lt;Event&gt; deque=new ArrayDeque&lt;Event&gt;(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; WriterTask writer=new WriterTask(deque); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (int i=0; i&lt;3; i++){ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread thread=new Thread(writer); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; thread.start(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; CleanerTask cleaner=new CleanerTask(deque); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; cleaner.start(); &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } </td> 
 </tr> 
 </tbody> 
</table>

#### 1.9、线程中不可控异常的处理 ####

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> 在java中有两种异常 1、&nbsp; 非运行时异常：必须throws抛出或者捕获，比如IOException、ClassNotFoundException 2、&nbsp; 运行时异常：不必显示处理，是程序执行的过程中出现的异常。 &nbsp; 因为run()方法不支持throws抛出异常，所以如果是非运行时必须处理时候，只能通过捕获来处理 如果出现运行时异常，会导致线程退出程序，需要手动去捕获处理异常，这里有两种方式，一种是手动try。。。catch，还有一种就是下面要讲解的在线程上设置捕获异常。 </td> 
 </tr> 
 <tr> 
 <td style="border-color:#000000;vertical-align:top;width:426.1pt;"> public class Task implements Runnable { &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp; public void run() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; int numero=Integer.parseInt("TTT"); &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; &nbsp; &nbsp; public class ExceptionHandler implements UncaughtExceptionHandler { &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; @Override&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; public void uncaughtException(Thread t, Throwable e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.printf("An exception has been captured\n"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.printf("Thread: %s\n",t.getId()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.printf("Exception: %s: %s\n",e.getClass().getName(),e.getMessage()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.printf("Stack Trace: \n"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(System.out); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.printf("Thread status: %s\n",t.getState()); &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; public class Main { &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Task task=new Task(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread thread=new Thread(task); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; thread.setUncaughtExceptionHandler(new ExceptionHandler()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; thread.start(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; thread.join(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (InterruptedException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; e.printStackTrace(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.printf("Thread has finished\n"); &nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } </td> 
 </tr> 
 </tbody> 
</table>

#### 1.10、线程局部变量的使用 ####

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> 通过继承Thread或者实现Runnable借口中，使用普通属性，会出现数据共享并发问题 可以通过ThreadLocal Variable线程局部变量来实现每个线程使用自己的单独属性 </td> 
 </tr> 
 <tr> 
 <td style="border-color:#000000;vertical-align:top;width:426.1pt;"> 异常程序：count被累加了，说明是共享的 </td> 
 </tr> 
 <tr> 
 <td style="border-color:#000000;vertical-align:top;width:426.1pt;"> public class UnsafeTask implements Runnable{ &nbsp; &nbsp;&nbsp;&nbsp; public int count=1; &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp; public void run() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; count++; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; public class Main { &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; UnsafeTask task=new UnsafeTask(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (int i=0; i&lt;10; i++){ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread thread=new Thread(task); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; thread.start(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println(task.count); &nbsp;&nbsp;&nbsp; } } </td> 
 </tr> 
 <tr> 
 <td style="border-color:#000000;vertical-align:top;width:426.1pt;"> 正确程序：count没有被累加，说明不是共享的 </td> 
 </tr> 
 <tr> 
 <td style="border-color:#000000;vertical-align:top;width:426.1pt;"> public class SafeTask implements Runnable { &nbsp; &nbsp;&nbsp;&nbsp; public static ThreadLocal&lt;Integer&gt; count= new ThreadLocal&lt;Integer&gt;() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; protected Integer initialValue(){ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return 1; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; }; &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp; public void run() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; count.set(count.get()+1); &nbsp;&nbsp;&nbsp; } &nbsp; } &nbsp; public class SafeMain { &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; SafeTask task=new SafeTask(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (int i=0; i&lt;10000; i++){ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread thread=new Thread(task); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; thread.start(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println(task.count.get()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } </td> 
 </tr> 
 </tbody> 
</table>

#### 1.11、线程的分组 ####

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> ThreadGroup tg = new ThreadGroup("ThreadGroup测试"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ThreadTask task1 = new ThreadTask(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ThreadTask task2 = new ThreadTask(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ThreadTask task3 = new ThreadTask(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread t1 = new Thread(tg,task1); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread t2 = new Thread(tg,task2); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread t3 = new Thread(tg,task3); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; t1.start(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; t2.start(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; t3.start(); </td> 
 </tr> 
 </tbody> 
</table>

#### 1.12、线程组中不可控异常的处理 ####

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> public class Task implements Runnable { &nbsp; &nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp; public void run() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Random random=new Random(Thread.currentThread().getId()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; while (true) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; int result=1000/((int)(random.nextDouble()*1000)); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (Thread.currentThread().isInterrupted()) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.printf("%d : Interrupted\n",Thread.currentThread().getId()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; } } &nbsp; &nbsp; public class MyThreadGroup extends ThreadGroup { &nbsp; &nbsp;&nbsp;&nbsp; public MyThreadGroup(String name) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; super(name); &nbsp;&nbsp;&nbsp; } &nbsp; &nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp; public void uncaughtException(Thread t, Throwable e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; interrupt(); &nbsp;&nbsp;&nbsp; } } &nbsp; &nbsp; public class Main { &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) { &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; MyThreadGroup threadGroup=new MyThreadGroup("MyThreadGroup"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Task task=new Task(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (int i=0; i&lt;2; i++){ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread t=new Thread(threadGroup,task); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; t.start(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; } &nbsp; } </td> 
 </tr> 
 </tbody> 
</table>

#### 1.13、使用工厂类创建线程 ####

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> public class Task implements Runnable { &nbsp; &nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp; public void run() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println(Thread.currentThread().getName()); &nbsp;&nbsp;&nbsp; } &nbsp; } </td> 
 </tr> 
 <tr> 
 <td style="border-color:#000000;vertical-align:top;width:426.1pt;"> &nbsp; public class MyThreadFactory implements ThreadFactory { &nbsp; &nbsp;&nbsp;&nbsp; private int counter; &nbsp;&nbsp;&nbsp; private String name; &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; public MyThreadFactory(String name){ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; counter=0; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.name=name; &nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; @Override &nbsp;&nbsp;&nbsp; public Thread newThread(Runnable r) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread t=new Thread(r,name+"-Thread_"+counter); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; counter++; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return t; &nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp; } </td> 
 </tr> 
 <tr> 
 <td style="border-color:#000000;vertical-align:top;width:426.1pt;"> &nbsp; public class Main { &nbsp; &nbsp;&nbsp;&nbsp; public static void main(String[] args) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; MyThreadFactory factory=new MyThreadFactory("MyThreadFactory"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Task task=new Task(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; for (int i=0; i&lt;110; i++){ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread thread = factory.newThread(task); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; thread.start(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; } &nbsp; } </td> 
 </tr> 
 </tbody> 
</table>