Worker Pattern(一)

xiaoxiao2026-08-14  37

前面谈了多线程应用程序能极大地改善用户相应。例如对于一个Web应用程序,每当一个用户请求服务器连接时,服务器就可以启动一个新线程为用户服务。 然而,创建和销毁线程本身就有一定的开销,如果频繁创建和销毁线程,CPU和内存开销就不可忽略,垃圾收集器还必须负担更多的工作。因此,线程池就是为了避免频繁创建和销毁线程。 每当服务器接受了一个新的请求后,服务器就从线程池中挑选一个等待的线程并执行请求处理。处理完毕后,线程并不结束,而是转为阻塞状态再次被放入线程池中。这样就避免了频繁创建和销毁线程。 Worker Pattern实现了类似线程池的功能。首先定义Task接口: package com.crackj2ee.thread; public interface Task { void execute(); } 线程将负责执行execute()方法。注意到任务是由子类通过实现execute()方法实现的,线程本身并不知道自己执行的任务。它只负责运行一个耗时的execute()方法。 具体任务由子类实现,我们定义了一个CalculateTask和一个TimerTask: // CalculateTask.java package com.crackj2ee.thread; public class CalculateTask implements Task { private static int count = 0; private int num = count; public CalculateTask() { count++; } public void execute() { System.out.println("[CalculateTask " + num + "] start..."); try { Thread.sleep(3000); } catch(InterruptedException ie) {} System.out.println("[CalculateTask " + num + "] done."); } } // TimerTask.java package com.crackj2ee.thread; public class TimerTask implements Task { private static int count = 0; private int num = count; public TimerTask() { count++; } public void execute() { System.out.println("[TimerTask " + num + "] start..."); try { Thread.sleep(2000); } catch(InterruptedException ie) {} System.out.println("[TimerTask " + num + "] done."); } } 以上任务均简单的sleep若干秒。 TaskQueue实现了一个队列,客户端可以将请求放入队列,服务器线程可以从队列中取出任务: package com.crackj2ee.thread; import java.util.*; public class TaskQueue { private List queue = new LinkedList(); public synchronized Task getTask() { while(queue.size()==0) { try { this.wait(); } catch(InterruptedException ie) { return null; } } return (Task)queue.remove(0); } public synchronized void putTask(Task task) { queue.add(task); this.notifyAll(); } }
转载请注明原文地址: https://www.6miu.com/read-5051226.html

最新回复(0)