package com.lj.demo5;
import java.util.LinkedList;
import java.util.Scanner;
/**
 * 多線程與集合綜合應(yīng)用示例
 * 演示線程池的初始化和任務(wù)提交過程
 * 
 * 應(yīng)用場景：
 * 如QQ聊天服務(wù)器，面對大量用戶連接時(shí)，
 * 使用線程池管理線程資源比為每個(gè)用戶創(chuàng)建新線程更高效
 */
public class PoolInit {
	// 存儲(chǔ)待執(zhí)行任務(wù)的鏈表，作為任務(wù)隊(duì)列
	public static LinkedList<String> linkTaskName = new LinkedList<String>();
	// 線程池實(shí)例
	public static ThreadPool t;
	public PoolInit() {
		// 初始化線程池，指定核心線程數(shù)為3
		t = new ThreadPool(3);
		// 從控制臺接收任務(wù)并提交給線程池
		Scanner scanner = new Scanner(System.in);
		String taskName = "";
		while (true) {
			System.out.println("請輸入線程需要處理的任務(wù)名稱：");
			taskName = scanner.next();
			// 將任務(wù)添加到任務(wù)隊(duì)列
			linkTaskName.add(taskName);
			// 提交第一個(gè)任務(wù)給線程池執(zhí)行
			t.executeTask(linkTaskName.get(0));
		}
	}
	public static void main(String[] args) {
		// 啟動(dòng)線程池
		new PoolInit();
	}
}

package com.lj.demo5;
import java.util.Vector;
/**
 * 線程池核心類
 * 管理工作線程，負(fù)責(zé)任務(wù)的分配與調(diào)度
 */
public class ThreadPool {
	// 線程池大小
	private int num;
	// 存儲(chǔ)工作線程的集合，使用Vector保證線程安全
	Vector<Runnable> vectors ;
	/**
	 * 構(gòu)造方法，初始化線程池
	 * @param num 線程池中的線程數(shù)量
	 */
	public ThreadPool(int num) {
		this.num = num;
		// 初始化線程集合，容量為指定的線程數(shù)量
		this.vectors = new Vector<Runnable>(this.num);
		System.out.println("線程集合當(dāng)前大?。? + this.vectors.size());
		System.out.println("線程集合容量：" + this.vectors.capacity());
		// 創(chuàng)建指定數(shù)量的工作線程并啟動(dòng)
		for(int i=0;i<this.vectors.capacity();i++) {
			WorkThread w = new WorkThread();
			this.vectors.add(w);
			w.start(); // 啟動(dòng)工作線程
		}
	}
	/**
	 * 執(zhí)行任務(wù)方法
	 * 查找空閑線程并分配任務(wù)
	 * @param taskName 任務(wù)名稱
	 */
	public void executeTask(String taskName) {
		// 遍歷線程池中的線程，尋找空閑線程
		for(int i=0;i<this.vectors.capacity();i++) {
			WorkThread w = (WorkThread) this.vectors.get(i);
			System.out.println("線程池中的線程" + w.getName() + "的狀態(tài)為:" + w.isFlag());
			// 如果線程處于空閑狀態(tài)（flag為false）
			if(!w.isFlag()) {
				System.out.println(w.getName() + ",現(xiàn)在是空閑狀態(tài)，分配新任務(wù)");
				// 設(shè)置線程為忙碌狀態(tài)
				w.setFlag(true);
				// 分配任務(wù)
				w.setTaskName(taskName);
				// 從任務(wù)隊(duì)列移除已分配的任務(wù)
				PoolInit.linkTaskName.remove(0);
				break; // 找到空閑線程后退出循環(huán)
			}
		}
	}
}

package com.lj.demo5;
/**
 * 工作線程類
 * 實(shí)際執(zhí)行任務(wù)的線程
 */
public class WorkThread extends Thread {
	// 線程狀態(tài)標(biāo)志：false表示空閑，true表示忙碌
	private boolean flag;
	// 當(dāng)前執(zhí)行的任務(wù)名稱
	private String taskName;
	/**
	 * 線程運(yùn)行方法
	 * 循環(huán)處理任務(wù)：有任務(wù)則執(zhí)行，無任務(wù)則等待
	 */
	@Override
	public synchronized void run() {
		while (true) {
			if (this.isFlag()) { // 有任務(wù)要執(zhí)行
				System.out.println(Thread.currentThread().getName() + "正在執(zhí)行任務(wù)：" + this.taskName);
				try {
					// 模擬任務(wù)執(zhí)行時(shí)間（30秒）
					Thread.sleep(30 * 1000);
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
				System.out.println(Thread.currentThread().getName() + "已完成任務(wù)：" + this.taskName + ",狀態(tài)變?yōu)榭臻e");
				// 任務(wù)完成，設(shè)置為空閑狀態(tài)
				this.setFlag(false);
			} else { // 無任務(wù)
				System.out.println("任務(wù)隊(duì)列中等待的任務(wù)數(shù)量：" + PoolInit.linkTaskName.size());
				// 檢查是否有未處理的任務(wù)
				if (PoolInit.linkTaskName.size() > 0) {
					String taskName = PoolInit.linkTaskName.get(0);
					PoolInit.t.executeTask(taskName);
					System.out.println(Thread.currentThread().getName() + 
							"發(fā)現(xiàn)未處理任務(wù)，嘗試處理：" + taskName);
				} else {
					System.out.println(Thread.currentThread().getName() + "：當(dāng)前沒有任務(wù)，進(jìn)入等待狀態(tài)...");
					try {
						// 進(jìn)入等待狀態(tài)，釋放鎖
						this.wait();
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
				}
			}
		}
	}
	// getter和setter方法
	public boolean isFlag() {
		return flag;
	}
	/**
	 * 設(shè)置線程狀態(tài)
	 * 當(dāng)設(shè)置為忙碌狀態(tài)時(shí)，喚醒等待的線程
	 */
	public synchronized void setFlag(boolean flag) {
		this.flag = flag;
		if (this.flag) {
			// 有新任務(wù)，喚醒線程
			this.notify();
		}
	}
	public String getTaskName() {
		return taskName;
	}
	public void setTaskName(String taskName) {
		this.taskName = taskName;
	}
}

package com.lj.data;
import javax.jws.WebMethod;
import javax.jws.WebService;
/**
 * WebService服務(wù)接口
 * 定義遠(yuǎn)程可調(diào)用的方法
 * 
 * RPC（遠(yuǎn)程過程調(diào)用）機(jī)制：
 * - RMI：客戶端和服務(wù)器端都必須是Java
 * - WebService：支持跨語言、跨平臺通信
 * - 其他：hessian, thrift, grpc, dubbo等
 */
@WebService(targetNamespace = "http://lj.com/wsdl")
public interface IAdminService {
	/**
	 * 定義WebService方法
	 * @return 字符串結(jié)果
	 */
	@WebMethod
	public String queryStr();
}

package com.lj.data.impl;
import javax.jws.WebService;
import com.lj.data.IAdminService;
/**
 * WebService服務(wù)實(shí)現(xiàn)類
 * 提供接口中定義的方法的具體實(shí)現(xiàn)
 */
@WebService(
    portName = "admin",//端口名稱
    serviceName = "AdminServiceImpl",//服務(wù)名稱
    targetNamespace = "http://lj.com/wsdl",//必須與接口的命名空間一致
    endpointInterface = "com.lj.data.IAdminService"http://指定實(shí)現(xiàn)的接口
)
public class AdminServiceImpl implements IAdminService {
	/**
	 * 實(shí)現(xiàn)查詢方法
	 * @return 返回示例字符串
	 */
	@Override
	public String queryStr() {
		return "你好，世界";
	}
}

package com.lj.webserviceclient;
import javax.xml.ws.Endpoint;
import com.lj.data.IAdminService;
import com.lj.data.impl.AdminServiceImpl;
/**
 * WebService服務(wù)發(fā)布類
 * 將服務(wù)發(fā)布到指定地址，供客戶端調(diào)用
 */
public class App {
    public static void main(String[] args) {
    	System.out.println("開始發(fā)布WebService遠(yuǎn)程服務(wù)...");
    	// 創(chuàng)建服務(wù)實(shí)現(xiàn)類實(shí)例
    	IAdminService adminService = new AdminServiceImpl();
    	// 發(fā)布服務(wù)，指定服務(wù)地址
    	Endpoint.publish("http://127.0.0.1:8225/AdminServiceImpl/admin", adminService);
    	System.out.println("WebService服務(wù)發(fā)布成功！");
    }
}

package com.lj.webserviceclient;
import java.net.URL;
import javax.xml.namespace.QName;
import javax.xml.ws.Service;
import com.lj.data.IAdminService;
/**
 * WebService客戶端
 * 調(diào)用遠(yuǎn)程發(fā)布的WebService服務(wù)
 */
public class App {
    public static void main(String[] args) {
        try {
        	// 服務(wù)的URL地址
            URL url = new URL("http://127.0.0.1:8225/AdminServiceImpl/admin");
            // 創(chuàng)建QName對象，指定命名空間和服務(wù)名稱
            QName qname = new QName("http://lj.com/wsdl", "AdminServiceImpl");
            // 創(chuàng)建Service對象
            Service service = Service.create(url, qname);
            // 獲取服務(wù)接口實(shí)例
            IAdminService adminService = service.getPort(IAdminService.class);
            // 調(diào)用遠(yuǎn)程方法
            String message = adminService.queryStr();
            System.out.println("調(diào)用遠(yuǎn)程WebService服務(wù)的結(jié)果為: " + message);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}