java代码关闭推送队列 java关闭弹窗

Java Thread队列详细代码的介绍

Java Thread队列一直是我们需要掌握的代码 下面我们就基本思想 建立了一个队列 为每一个Java Thread队列保存了一个对象锁 保证按顺序执行 线程启动的时候 使随机的 但梁桐运是执行代码是按顺序的

创新互联建站坚持“要么做到，要么别承诺”的工作理念，服务领域包括：成都网站建设、做网站、企业官网、英文网站、手机端网站、网站推广等服务，满足客户于互联网时代的松江网站设计、移动媒体设计的需求，帮助企业找到有效的互联网解决方案。努力成为您成熟可靠的网络建设合作伙伴！

import java util LinkedList;

import java util Queue;

public class ThreadTest {

private static Queue qThread=new LinkedList();//线程同步对象队列

public static synchronized void putObject(Object t){

qThread offer(t);

}

public static synchronized Object getObject(){

return qThread poll();

}

public static void waitThread(Object t) throws InterruptedException{

synchronized(t){

t wait();

}

}

public static void notifyThread(){

Object obj=ThreadTest getObject();

synchronized(obj){

obj notify();

}

}

public static void main(String[] args) throws InterruptedException {

int i = ;

boolean isFirst=true;

while (i ) {

Object obj=new Object();

if(i ){

isFirst=false;

ThreadTest putObject(obj);

}

Thread t = new Thread (isFirst obj);

Object obj =new Object();

ThreadTest putObject(obj );

Thread t = new Thread (obj );

t start();

t start();

i++;

}

}

}

/**

* 线程

　橡梁　 *

* @author Harry WANG

*

*/

class Thread extends Thread {

private boolean isFirst=false;

private Object obj;

public Thread (boolean f Object obj){

this isFirst=f;

this obj=obj;

}

@Override

public void run() {

if(!this isFirst){

System out println(this getName()+ 等待 );

try{

ThreadTest waitThread(obj);

}catch(InterruptedException e){

e printStackTrace();

}

}

System out println( 启动 +this getName()+ );

try {

sleep( );//等待 秒 为了测试

} catch (InterruptedException e) {

　轮租　 e printStackTrace();

}

System out println( 停止 +this getName()+ );

ThreadTest notifyThread();

}

}

class Thread extends Thread {

private Object obj;

public Thread (Object obj){

this obj=obj;

}

@Override

public void run() {

System out println(this getName()+ 等待 );

try{

ThreadTest waitThread(obj);

}catch(InterruptedException e){

e printStackTrace();

}

System out println( 启动 +this getName()+ );

try {

sleep( );//等待 秒 为了测试

} catch (InterruptedException e) {

e printStackTrace();

}

System out println( 停止 +this getName()+ );

ThreadTest notifyThread();

}

}

lishixinzhi/Article/program/Java/hx/201311/27018