java线程自己去取消息处理

       这次说的就是想要线程自己去找事情做的一个方法，逻辑思想就是，当有人像我们的容器中放置一个新的消息，那么唤醒所有线程，这个时候取消息加锁并且位移+1，然后处理线程自己思考是否还有消息应该处理，如果没有进入等待空间，如果有责继续处理！

       （这种处理思想是考虑到线程共享内存的原理，否则是无法实现的）

package threadtest2;

public class Main {
	public static void main(String[] args){
		Channel channel = new Channel(5);				//生成一个新的channel对象，设置容器线程量为5
		channel.startWorkers();							//开始所有的工作线程
		new ClientThread("Alice", channel).start();		//启动客户端模拟器来放置消息
		new ClientThread("Bobby", channel).start();		//同上
		new ClientThread("Chris", channel).start();		//同上
	}
}

 

package threadtest2;

public class Main {
	public static void main(String[] args){
		Channel channel = new Channel(5);				//生成一个新的channel对象，设置容器线程量为5
		channel.startWorkers();							//开始所有的工作线程
		new ClientThread("Alice", channel).start();		//启动客户端模拟器来放置消息
		new ClientThread("Bobby", channel).start();		//同上
		new ClientThread("Chris", channel).start();		//同上
	}
}

        这类的代码其实都是简单

package threadtest2;

import java.util.Random;
public class Request {
	private final String name;		//委托者名称
	private final int number;		//请求编号
	private static final Random random = new Random();	//生成一个随机数
	public Request(String name, int number){
		this.name = name;
		this.number = number;
	}
	
	/**work线程调用使用的解决方法，就是简单的显示**/
	public void execute(){
		System.out.println(Thread.currentThread().getName() + "executes" + this);
		try{
			Thread.sleep(random.nextInt(1000));
		}catch(InterruptedException e){
			
		}
	}
	
	public String toString(){
		return "[ Request from]" + name + "No." + number +"]";
	}
}

 

package threadtest2;

import java.util.Random;
public class Request {
	private final String name;		//委托者名称
	private final int number;		//请求编号
	private static final Random random = new Random();	//生成一个随机数
	public Request(String name, int number){
		this.name = name;
		this.number = number;
	}
	
	/**work线程调用使用的解决方法，就是简单的显示**/
	public void execute(){
		System.out.println(Thread.currentThread().getName() + "executes" + this);
		try{
			Thread.sleep(random.nextInt(1000));
		}catch(InterruptedException e){
			
		}
	}
	
	public String toString(){
		return "[ Request from]" + name + "No." + number +"]";
	}
}

 

package threadtest2;

import java.util.Random;

/**模拟客户端发送请求**/
public class ClientThread extends Thread{
	private final Channel channel;						//创建处理模块实例
	private static final Random random = new Random();	//生成随机数
	public ClientThread(String name, Channel channel){	
			super(name);								//继承线程类构造方法
			this.channel = channel;						
	}
	
	/**实现run方法**/
	public void run(){									
		try{
			/**该进程一直递增，并调用channel put方法来放置新的消息进去，然后随机休眠等待**/
			for(int i = 0; true; i++){
				Request request = new Request(getName(), i);
				channel.putRequest(request);
				Thread.sleep(random.nextInt(1000));
			}
		}catch(InterruptedException e){
		}
	}

}

        这中简单的小示例代码，经过我们的修改，可以制作成处理很复杂逻辑的代码版本，例如，我们将存储消息的数组加以分类，让线程按照类别去寻找消息处理等等！