Java中有关多线程并发的几个工具类之总结

[农村基层组织建设中应着重处理好的几个关系]农村基层组织建设中应着重处理好的几个关系党的基层组织是党的社会基层组织中的战斗堡垒，是党的全部工作和战斗力的基础，是联系人民群众的桥梁和纽带。九象网23: .9xwang.农村...+阅读

Java中有关多线程并发的几个工具类之总结

FixedThreadPool模式会使用一个优先固定数目的线程来处理若干数目的任务。规定数目的线程处理所有任务，一旦有线程处理完了任务就会被用来处理新的任务（如果有的话）。这种模式与上面的CachedThreadPool是不同的，CachedThreadPool模式下处理一定数量的任务的线程数目是不确定的。而FixedThreadPool模式下最多的线程数目是一定的。

采用FixedThreadPool模式编写客户端程序如下：packagenet.jerryblog.concurrent;importjava.util.concurrent.ExecutorService;importjava.util.concurrent.Executors;publicclassFixedThreadPool{publicstaticvoidmain(String[]args){

//三个线程来执行五个任务

ExecutorServiceexec=Executors.newFixedThreadPool(3);for(inti=0;i<5;i++){exec.execute(newLiftOff());}exec.shutdown();}}

3.SingleThreadExecutor模式

SingleThreadExecutor模式只会创建一个线程。它和FixedThreadPool比较类似，不过线程数是一个。如果多个任务被提交给SingleThreadExecutor的话，那么这些任务会被保存在一个队列中，并且会按照任务提交的顺序，一个先执行完成再执行另外一个线程。

SingleThreadExecutor模式可以保证只有一个任务会被执行。这种特点可以被用来处理共享资源的问题而不需要考虑同步的问题。

SingleThreadExecutor模式编写的客户端程序如下：packagenet.jerryblog.concurrent;importjava.util.concurrent.ExecutorService;importjava.util.concurrent.Executors;publicclassSingleThreadExecutor{publicstaticvoidmain(String[]args){

ExecutorServiceexec=Executors.newSingleThreadExecutor();for(inti=0;i<2;i++){exec.execute(newLiftOff（)）；}}}这种模式下执行的结果如下：

#0(9)#0(8)#0(7)#0(6)#0(5)#0(4)#0(3)#0(2)#0(1)#0(LiftOff!)

第一个任务执行完了之后才开始执行第二个任务。

java多线程并发怎么实现

public class SayHello(){public void sayHello(){system.out.println(＂hello＂)}}public class ThreadA implements Runable{private SayHello sh;public void run(){while(true){sh.sayHello();} }public void setSayHello(SayHello sh){this.sh=sh}}public class ThreadB implements Runable{private SayHello sh;public void run(){while(true){sh.sayHello();} }public void setSayHello(SayHello sh){this.sh=sh}}public Class Test{public static void main(String[] arg){SayHello sh=new SayHello():ThreadA ta=new ThreadA();ta.setSayHello(sh);ThreadB tb=new ThreadB(); tb.setSayHello(sh);Thread t=new Thread(ta);Thread t2=new thread(tb);t.start();t2.start()}}...

求java多线程实例

import java.io.*;

public class C1 implements Runnable {

String C1Name;

public C1(String C32Name){

this.C1Name=C1Name;

}

public void run(){

try {

Thread.sleep(Math.round(Math.random()*1000));

}catch(InterruptedException e){

}

System.out.println（＂在run方法中：＂+C1Name）;

}

public static void main(String args[]){

C1 in1=new C1（＂实例1＂）;

C1 in2=new C1（＂实例2＂）;

Thread t1=new Thread(in1);

Thread t2=new Thread(in2);

t1.start();

System.out.println（＂实例1创建了新线程＂）；

t2.start();

System.out.println（＂实例2创建了新线程＂）；

}

在java中怎样写个多线程并发

多线程有两种形式，一种是直接让当前类继承 Thread 重写run方法来实现，另一种是使用 Runnable接口。推荐第二种方法。

例：

public class Counter {

public volatile static int count = 0;

public static void inc() {

//这里延迟1秒，使得结果明显

try {

Thread.sleep(1000);

} catch (InterruptedException e) {

}

count++;

}

public static void main(String[] args) {

//同时启动1000个线程，去进行i++计算，看看实际结果

for (int i = 0; i new Thread(new Runnable() {

Override

public void run() {

Counter.inc();

}

}).start();

}

//这里每次运行的值都有可能不同，可能不为1000

System.out.println（＂运行结果：Counter.count=＂ + Counter.count）;

}