如何使用Java编写多线程程序

米嘉尔

米嘉尔

2016-02-19 12:01

今天图老师小编给大家展示的是如何使用Java编写多线程程序,精心挑选的内容希望大家多多支持、多多分享,喜欢就赶紧get哦!
一、简介

1、什么是线程

要说线程,就必须先说说进程,进程就是程序的运行时的一个实例。线程呢可以看作单独地占有CPU时间来执行相应的代码的。对早期的计算机(如DOS)而言,线程既是进程,进程既是进程,因为她是单线程的。当然一个程序可以是多线程的,多线程的各个线程看上去像是并行地独自完成各自的工作,就像一台一台计算机上运行着多个处理机一样。在多处理机计算机上实现多线程时,它们确实可以并行工作,而且采用适当的分时策略可以大大提高程序运行的效率。但是二者还是有较大的不同的,线程是共享地址空间的,也就是说多线程可以同时读取相同的地址空间,并且利用这个空间进行交换数据。

2、为什么要使用线程

为什么要使用多线程呢?学过《计算机体系结构》的人都知道。将顺序执行程序和采用多线程并行执行程序相比,效率是可以大大地提高的。比如,有五个线程thread1, thread2, thread3, thread4, thread5,所耗的CPU时间分别为4,5,1,2,7。(假设CPU轮换周期为4个CPU时间,而且线程之间是彼此独立的)顺序执行需要花费19个CPU时间,而并行需要的时间肯定少于19个CPU时间,至于具体多少时间要看那些线程是可以同时执行的。这是在非常小规模的情况下,要是面对大规模的进程之间的交互的话,效率可以表现得更高。

3、java中是如何实现多线程的

与其他语言不一样的是,线程的观念在java是语言中是重要的,根深蒂固的,因为在java语言中的线程系统是java语言自建的, java中有专门的支持多线程的API库,所以你可以以最快的速度写一个支持线程的程序。在使用java创建线程的时候,你可以生成一个Thread类或者他的子类对象,并给这个对象发送start()消息(程序可以向任何一个派生自 Runnable 接口的类对象发送 start() 消息的),这样一来程序会一直执行,直到run返回为止,此时该线程就死掉了。

在java语言中,线程有如下特点:

§ 在一个程序中而言,主线程的执行位置就是main。而其他线程执行的位置,程序员是可以自定义的。值得注意的是对Applet也是一样。

§ 每个线程执行其代码的方式都是一次顺序执行的。

§ 一个线程执行其代码是与其他线程独立开来的。如果诸线程之间又相互协作的话,就必须采用一定的交互机制。

§ 前面已经说过,线程是共享地址空间的,如果控制不当,这里很有可能出现死锁。

各线程之间是相互独立的,那么本地变量对一个线程而言就是完全独立,私有的。所以呢,线程执行时,每个线程都有各自的本地变量拷贝。对象变量(instance variable)在线程之间是可以共享的,这也就是为什么在java中共享数据对象是如此的好用,但是java线程不能够武断地访问对象变量:他们是需要访问数据对象的权限的。

二、准备知识

在分析这个例子之前,然我们先看看关于线程的几个概念,上锁,信号量,和java所提供的API。

上锁

对于大多数的程序而言,他们都需要线程之间相互的通讯来完成整个线程的生命周期,二实现线程之间同步的最简单的办法就是上锁。为了防止相互关联的两个线程之间错误地访问共享资源,线程需要在访问资源的时候上锁和解锁,对于锁而言,有读锁,写锁和读写锁等不同的同步策略。在java中,所有的对象都有锁;线程只需要使用synchronized关键字就可以获得锁。在任一时刻对于给定的类的实例,方法或同步的代码块只能被一个线程执行。这是因为代码在执行之前要求获得对象的锁。

信号量

通常情况下,多个线程所访问为数不多的资源,那怎么控制呢?一个比较非常经典而起非常简单的办法就是采用信号量机制。信号量机制的含义就是定义一个信号量,也就是说能够提供的连接数;当有一个线程占用了一个连接时,信号量就减一;当一个线程是放了连接时,信号量就加一。采用这种方法就可以简单有效地控制线程的同步问题,而且实现起来也特别方便。看下面的代码:

class Semaphore {

private int count;

public Semaphore(int count) {

this.count = count;

}

public synchronized void acquire() {

while(count == 0) {

try {

wait();

} catch (InterruptedException e) {

//keep trying

}

}

count--;

}

public synchronized void release() {

count++;

notify(); //alert a thread that′s blocking on this semaphore

}

}

java中提供了哪些api以编写多线程程序

这里只列出几个常用的方法和属性值。

属性值,有三个MAX_PRIORITY,MIN_PRIORITY,NORM_PRIORITY

方法:

Thread(); //建立一个线程

void run(); //对于一个继承了Runnable接口的class而言,

//他运行一个线程,否着他什么都不做

void setPriority(int newPriority); //设置优先级

void start(); //运行一个程序

void sleep(long millis); //线程睡眠millis毫秒

static void yield(); //临时pause一个程序以便起他线程运行

三、程序示例

例一、

(本文来源于图老师网站,更多请访问https://m.tulaoshi.com/bianchengyuyan/)

让我们看看下面的例子。取钱的流程是输入密码,然后确定要取得金额,如果所取的金额小于或等于可以取出的金额,WITHDRAW则返回TRUE,然后ATM机出钱,然后打印清单;否则返回FALSE,然后打印清单。如下图:

public class AutomatedTellerMachine extends Teller {

public void withdraw(float amount) {

Account a = getAccount();

if (a.deduct(amount))

(本文来源于图老师网站,更多请访问https://m.tulaoshi.com/bianchengyuyan/)

dispense(amount);

printReceipt();

}

}

public class Account {

private float total;

public boolean deduct(float t) {

if (t = total) {

total -= t;

return true;

}

return false;

}

}

就这个例子而言,假设有这种情况,对同一个账号可以在不同的地方取钱,在同一时间,不同地点,妻子和丈夫取钱,妻子输入了账号上的最大金额,丈夫也是一样,假如妻子输入后已经得到true的返回值,但是丈夫的线程所得到的值还没有更新,这样丈夫也能够得到true的返回值,这样就出现了问题!这个问题怎么解决呢?在java里面提供了控制机制以保证deduct操作时的原子性,那就是关键字synchronized。

在Account的deduct方法加入synchronized就可以解决这个问题。

例二、

在这里我们用多线程中最典型的例子,生产者与消费者问题。在这个例子里面我们定义了生产者Producer,消费者Consumer和仓库Warehouse三个类,在整个程序的生命周期里,生产者随机地制造出产品放到仓库中,消费者也是随即地从仓库中取出产品。

import exception.ProducerConsumerException;

/**

* Consumer.j

展开更多 50%)
分享

猜你喜欢

如何使用Java编写多线程程序

编程语言 网络编程
如何使用Java编写多线程程序

Java多线程程序设计

Java JAVA基础
Java多线程程序设计

s8lol主宰符文怎么配

英雄联盟 网络游戏
s8lol主宰符文怎么配

Java 程序中的多线程

编程语言 网络编程
Java 程序中的多线程

Java多线程程序设计初步

编程语言 网络编程
Java多线程程序设计初步

lol偷钱流符文搭配推荐

英雄联盟 网络游戏
lol偷钱流符文搭配推荐

浅析Java多线程程序设计机制

编程语言 网络编程
浅析Java多线程程序设计机制

Java多线程程序设计详细解析

编程语言 网络编程
Java多线程程序设计详细解析

lolAD刺客新符文搭配推荐

英雄联盟
lolAD刺客新符文搭配推荐

温热冰封的心肠 - QQ情侣分组

温热冰封的心肠 - QQ情侣分组

用Java Swing作一个日历控制程序

用Java Swing作一个日历控制程序
下拉加载更多内容 ↓