展开全部
public class Add1to10 {
/**
* @param args
*/
private int total = 0;
public int getTotal(){
return total;
}
public void setTotal(int t){
total = t;
}
public static void main(String[] args) {
// TODO 自动生成方法存根
Add1to10 add = new Add1to10();
Add1 a1 = new Add1(add);
Runnable r1 = new Add2(add);
Thread a2 = new Thread(r1);
a1.start();
a2.start();
}
}
class Add1 extends Thread{
Add1to10 sum;
public Add1(Add1to10 sum){
this.sum = sum;
}
public synchronized void add(int i){
sum.setTotal(sum.getTotal()+i);
System.out.println("t1:"+sum.getTotal());
}
public void run(){
for(int i=1;i<=5;i++){
add(i);
try {
Thread.sleep(200);
} catch (InterruptedException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
}
}
}
}
class Add2 implements Runnable{
Add1to10 sum;
public Add2(Add1to10 sum){
this.sum = sum;
}
public synchronized void add(int i){
sum.setTotal(sum.getTotal()+i);
System.out.println("t2:"+sum.getTotal());
}
public void run() {
for(int i = 6;i<=10;i++){
add(i);
try {
Thread.sleep(50);
} catch (InterruptedException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
}
}
// TODO 自动生成方法存根
}
}
/**
* @param args
*/
private int total = 0;
public int getTotal(){
return total;
}
public void setTotal(int t){
total = t;
}
public static void main(String[] args) {
// TODO 自动生成方法存根
Add1to10 add = new Add1to10();
Add1 a1 = new Add1(add);
Runnable r1 = new Add2(add);
Thread a2 = new Thread(r1);
a1.start();
a2.start();
}
}
class Add1 extends Thread{
Add1to10 sum;
public Add1(Add1to10 sum){
this.sum = sum;
}
public synchronized void add(int i){
sum.setTotal(sum.getTotal()+i);
System.out.println("t1:"+sum.getTotal());
}
public void run(){
for(int i=1;i<=5;i++){
add(i);
try {
Thread.sleep(200);
} catch (InterruptedException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
}
}
}
}
class Add2 implements Runnable{
Add1to10 sum;
public Add2(Add1to10 sum){
this.sum = sum;
}
public synchronized void add(int i){
sum.setTotal(sum.getTotal()+i);
System.out.println("t2:"+sum.getTotal());
}
public void run() {
for(int i = 6;i<=10;i++){
add(i);
try {
Thread.sleep(50);
} catch (InterruptedException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
}
}
// TODO 自动生成方法存根
}
}
展开全部
多线程并行计算,一般用在大量数据时,分段进行计算,最后进行结果合并;按任务复杂度,设置好分成几份,分几个线程;呵呵呀呀
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
展开全部
public class TestThreadOne extends Thread{
public static int sum=0;
public void run(){
for (int i=1;i<=10 ;i++ )
{
sum=sum+i;
}
System.out.println("1+2+3+4+...+10="+sum);
}
public static void main(String[] args){
TestThreadOne t=new TestThreadOne();
t.start();
}
}
public static int sum=0;
public void run(){
for (int i=1;i<=10 ;i++ )
{
sum=sum+i;
}
System.out.println("1+2+3+4+...+10="+sum);
}
public static void main(String[] args){
TestThreadOne t=new TestThreadOne();
t.start();
}
}
已赞过
已踩过<
评论
收起
你对这个回答的评价是?
推荐律师服务:
若未解决您的问题,请您详细描述您的问题,通过百度律临进行免费专业咨询
广告 您可能关注的内容 |