正文
java案例代码与解析 java案例代码与解析的区别
提示：扫一扫查出行【扫一扫了解最新限行尾号】
复制提示
JAVA模拟生产者与消费者实例
使用的生产者和消费者模型具有如下特点：
(1)本实验的多个缓冲区不是环形循环的，也不要求按顺序访问。生产者可以把产品放到目前某一个空缓冲区中。
(2)消费者只消费指定生产者的产品。
(3)在测试用例文件中指定了所有的生产和消费的需求，只有当共享缓冲区的数据满足了所有关于它的消费需求后，此共享缓冲区才可以作为空闲空间允许新的生产者使用。
(4)本实验在为生产者分配缓冲区时各生产者间必须互斥，此后各个生产者的具体生产活动可以并发。而消费者之间只有在对同一产品进行消费时才需要互斥，同时它们在消费过程结束时需要判断该消费对象是否已经消费完毕并清除该产品。
Windows
用来实现同步和互斥的实体。在Windows
中，常见的同步对象有：信号量(Semaphore)、
互斥量(Mutex)、临界段(CriticalSection)和事件(Event)等。本程序中用到了前三个。使用这些对象都分
为三个步骤，一是创建或者初始化：接着请求该同步对象，随即进入临界区，这一步对应于互斥量的
上锁；最后释放该同步对象，这对应于互斥量的解锁。这些同步对象在一个线程中创建，在其他线程
中都可以使用，从而实现同步互斥。当然，在进程间使用这些同步对象实现同步的方法是类似的。
1．用锁操作原语实现互斥
为解决进程互斥进人临界区的问题，可为每类临界区设置一把锁，该锁有打开和关闭两种状态，进程执行临界区程序的操作按下列步骤进行：
①关锁。先检查锁的状态，如为关闭状态，则等待其打开；如已打开了，则将其关闭，继续执行步骤②的操作。
②执行临界区程序。
③开锁。将锁打开，退出临界区。
2．信号量及WAIT，SIGNAL操作原语
信号量的初值可以由系统根据资源情况和使用需要来确定。在初始条件下信号量的指针项可以置为0，表示队列为空。信号量在使用过程中它的值是可变的，但只能由WAIT，SIGNAL操作来改变。设信号量为S，对S的WAIT操作记为WAIT（S），对它的SIGNAL操作记为SIGNAL（S）。
WAIT（S）：顺序执行以下两个动作：
①信号量的值减1，即S=S－1；
②如果S≥0，则该进程继续执行；
如果
S（0，则把该进程的状态置为阻塞态，把相应的WAITCB连人该信号量队列的末尾，并放弃处理机，进行等待（直至其它进程在S上执行SIGNAL操作，把它释放出来为止）。
SIGNAL（S）：顺序执行以下两个动作
①S值加
1，即
S=S＋1；
②如果S）0，则该进程继续运行；
如果S（0则释放信号量队列上的第一个PCB（既信号量指针项所指向的PCB）所对应的进程（把阻塞态改为就绪态），执行SIGNAL操作的进程继续运行。
在具体实现时注意，WAIT，SIGNAL操作都应作为一个整体实施，不允许分割或相互穿插执行。也就是说，WAIT，SIGNAL操作各自都好像对应一条指令，需要不间断地做下去，否则会造成混乱。
从物理概念上讲，信号量S）时，S值表示可用资源的数量。执行一次WAIT操作意味着请求分配一个单位资源，因此S值减1；当S0时，表示已无可用资源，请求者必须等待别的进程释放了该类资源，它才能运行下去。所以它要排队。而执行一次SIGNAL操作意味着释放一个单位资源，因此S值加1；若S（0时，表示有某些进程正在等待该资源，因而要把队列头上的进程唤醒，释放资源的进程总是可以运行下去的。
---------------
/**
*
生产者
*
*/
public
class
Producer
implements
Runnable{
private
Semaphore
mutex,full,empty;
private
Buffer
buf;
String
name;
public
Producer(String
name,Semaphore
mutex,Semaphore
full,Semaphore
empty,Buffer
buf){
this.mutex
=
mutex;
this.full
=
full;
this.empty
=
empty;
this.buf
=
buf;
this.name
=
name;
}
public
void
run(){
while(true){
empty.p();
mutex.p();
System.out.println(name+"
inserts
a
new
product
into
"+buf.nextEmptyIndex);
buf.nextEmptyIndex
=
(buf.nextEmptyIndex+1)%buf.size;
mutex.v();
full.v();
try
{
Thread.sleep(1000);
}
catch
(InterruptedException
e)
{
e.printStackTrace();
}
}
}
}
---------------
/**
*
消费者
*
*/
public
class
Customer
implements
Runnable{
private
Semaphore
mutex,full,empty;
private
Buffer
buf;
String
name;
public
Customer(String
name,Semaphore
mutex,Semaphore
full,Semaphore
empty,Buffer
buf){
this.mutex
=
mutex;
this.full
=
full;
this.empty
=
empty;
this.buf
=
buf;
this.name
=
name;
}
public
void
run(){
while(true){
full.p();
mutex.p();
System.out.println(name+"
gets
a
product
from
"+buf.nextFullIndex);
buf.nextFullIndex
=
(buf.nextFullIndex+1)%buf.size;
mutex.v();
empty.v();
try
{
Thread.sleep(1000);
}
catch
(InterruptedException
e)
{
e.printStackTrace();
}
}
}
}
-------------------------
/**
*
缓冲区
*
*/
public
class
Buffer{
public
Buffer(int
size,int
nextEmpty,int
nextFull){
this.nextEmptyIndex
=
nextEmpty;
this.nextFullIndex
=
nextFull;
this.size
=
size;
}
public
int
size;
public
int
nextEmptyIndex;
public
int
nextFullIndex;
}
-----------------
/**
*
此类用来模拟信号量
*
*/
public
class
Semaphore{
private
int
semValue;
public
Semaphore(int
semValue){
this.semValue
=
semValue;
}
public
synchronized
void
p(){
semValue--;
if(semValue0){
try
{
this.wait();
}
catch
(InterruptedException
e)
{
e.printStackTrace();
}
}
}
public
synchronized
void
v(){
semValue++;
if(semValue=0){
this.notify();
}
}
}
------------------------
public
class
Test
extends
Thread
{
public
static
void
main(String[]
args)
{
Buffer
bf=new
Buffer(10,0,0);
Semaphore
mutex=new
Semaphore(1);
Semaphore
full=new
Semaphore(0);
Semaphore
empty=new
Semaphore(10);
//new
Thread(new
Producer("p001",mutex,full,empty,bf)).start();
Producer
p=new
Producer("p001",mutex,full,empty,bf);
new
Thread(new
Producer("p002",mutex,full,empty,bf)).start();
new
Thread(new
Producer("p003",mutex,full,empty,bf)).start();
new
Thread(new
Producer("p004",mutex,full,empty,bf)).start();
new
Thread(new
Producer("p005",mutex,full,empty,bf)).start();
try{
sleep(3000);
}
catch(Exception
ex)
{
ex.printStackTrace();
}
new
Thread(new
Customer("c001",mutex,full,empty,bf)).start();
new
Thread(new
Customer("c002",mutex,full,empty,bf)).start();
new
Thread(new
Customer("c003",mutex,full,empty,bf)).start();
new
Thread(new
Customer("c004",mutex,full,empty,bf)).start();
new
Thread(new
Customer("c005",mutex,full,empty,bf)).start();
}
}
--------------------------------------------
相关问答
Q1: 急求java方向的参考书？最好含有案例和代码解释的。谢谢！
文轩网这里帮你搜索了2本供参考
JAVA高手真经(高级编程卷):JAVA WEB高级开发技术(EJB+消息通信+分布式+开源框架)(含光盘1张)
刘中兵Java研究室 编著 著 电子工业出版社
本书讲解Java Web开发中的高级开发技术，包括企业级的开发技术EJB、各种Java EE的分布式开发技术、Java Web的各种开源技术与框架，这3部分内容层层递进，涵盖…
----------------------------
Java解惑
（美）布洛克 （美）加夫特 著 人民邮电出版社
《Java解惑》特写了95个有关Java或其类库的陷阱和缺陷的谜题，其中大多数谜题都采用短程序的形式给出，这些程序的实际行为与表面上大相径庭。在每个谜题之后都给出了详细的解惑方案，…
----------------------------
书多，你到文轩网搜索java，慢慢选
Q2: java atm源代码解析
先不说公司的保密协议
一个项目的代码能在这里全贴出来java案例代码与解析，还给你讲解的清楚？
、不过整个取款机流程是很简单的java案例代码与解析，就是用户进行不同的操作，
java 调用 JNI驱动硬件执行相应的操作，关键就是组织各种类型的报文，
通过DTU发送到银联那边，比如说支付报文，冲正报文，日结报文……
这些报文的组织一般java 也只管传入JNI 中C++组装好以后再调用 DTU驱动发送
java 这一块就是处理一些逻辑或者页面流转之类的、
代码是不可能贴的，保密协议还是有一定的约束力的
MyView myView = new MyView();
myView.anyView = this;
this.remove(this.xxPanel);
this.add(myView.getPanel());
this.repaint();
Q3: java问题，求详解
首先java案例代码与解析，这个是javascript问题，不是java问题。
其次，这个问题是
var c = (a++)+b导致java案例代码与解析的。
先用后加典型案例。
于是c = a + b 执行完后 a+1
如果是
var c = ++a+b就是 4 2 6java案例代码与解析了 先加后用
Q4: 哪位大神帮看看 Java 如何解析 如下图的xml 最好能有个案例
XmlPullParser parse=Xml.newPullParser();
parse.setInput(is, "UTF-8");
int eventType=parse.getEventType();
while((eventType=parse.next())!=XmlPullParser.END_DOCUMENT)
{
switch(eventType)
{
case XmlPullParser.START_TAG:
if(parse.getName().equals("contacts"))
{
contacts=new ArrayListContact();
}
else if(parse.getName().equals("contact"))
{
contact=new Contact();
contact.setId(Integer.valueOf(parse.getAttributeValue(0)));
}
else if(parse.getName().equals("name"))
{
contact.setContactName(parse.nextText());
}
else if(parse.getName().equals("price"))
{
contact.setPrice(Integer.valueOf(parse.nextText()));
}
else if(parse.getName().equals("image"))
{
contact.setImage(parse.getAttributeValue(0));
}
break;
case XmlPullParser.END_TAG:
if(parse.getName().equals("contact"))
{
contacts.add(contact);
}
break;
}
}
?xml version="1.0" encoding="UTF-8"?
contacts
contact id="1"
name好吃的很/name
price10/price
/contact
contact id="2"
name味道很舒服/name
price11/price
/contact
contact id="3"
name样子很安逸/name
price12/price
/contact
contact id="4"
name颜色黑诱人/name
price13/price
/contact
contact id="5"
name再来一碗/name
price14/price
/contact
contact id="6"
name赞不绝口的说/name
price15/price
/contact
contact id="7"
namefood7/name
price16/price
/contact
contact id="8"
namefood8/name
price17/price
/contact
contact id="9"
namefood9/name
price18/price
/contact
/contacts
Q5: 急求java代码的详解析 bt_9.setOnClickListener(new OnClickListener(){ public void onClick(View v){ str
Button19.setOnClickListener(new View.OnClickListener() {//添加一个OnClickListener接口的匿名实例/对象
public void onClick(View v) {//当click事件发生时会调用这个onclick方法
// TODO Auto-generated method stub
if (str_result!=""){//1：判断字符串是否与空串常量的内存地址相同，凡是在源代码中出现的"xxxxx"，统统属于全局静态常量。字符串比较千万别用“==”“!=”。
double b = Double.parseDouble(str_result);
//2：把str_result的字符串转为double类型的数据
str_result = ""+b*b;
//3：把str_result设为b的平方。""+数值型 ——〉转为字符串类型
entry.setText(String.valueOf(str_result));
//4：把entry的显示文字设为str_result，也即原来的输入的数字的平方。String.valueOf用得有点多余。
}
}
}
//以下的看来是对上面那段毛病代码的修正。
if(str_oper.equals("*")){//对代码1的修正，这才是判断字符串内容是否相同。
g=Double.parseDouble(str_display.toString());//跟代码2一个意思，只是转换的对象是一个字符串缓冲区里的字符串。这里不明白为什么要使用字符串缓冲区。
str_result=String.valueOf((b*g));
//等价于代码3。两者都对。
entry.setText(str_result);
//等价于代码4。
str_display=new StringBuffer("");
//为str_display开辟一个新的字符串缓冲区。字符串缓冲区的作用是避免每一次字符串拼接修改都得new一个字符串对象。这里是干吗用的，由于没看到完整程序，不清楚。
关于java案例代码与解析和java案例代码与解析的区别的介绍到此就结束了，不知道你从中找到你需要的信息了吗 ？如果你还想了解更多这方面的信息，记得收藏关注本站。
