- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我知道如何正确执行此操作,但我想知道为什么这段代码会按照我的意愿运行,**没有任何明显的错误**,而如果我删除 Thread.sleep(100); 从两个while循环开始,程序进入无限循环的情况?
import java.util.Random;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.Random;
import java.util.Random;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
interface Buffer
{
// place int value into Buffer
public void set( int value ) throws InterruptedException;
// obtain int value from Buffer
public int get() throws InterruptedException;
} // end interface Buffer
public class javaapplication32
{
public static void main( String[] args )
{
// create new thread pool with two threads
ExecutorService application = Executors.newCachedThreadPool();
// create CircularBuffer to store ints
CircularBuffer sharedLocation = new CircularBuffer();
// display the initial state of the CircularBuffer
sharedLocation.displayState( "Initial State" );
// execute the Producer and Consumer tasks
application.execute( new Producer( sharedLocation ) );
application.execute( new Consumer( sharedLocation ) );
application.shutdown();
} // end main
}
// Consumer.java
// Consumer's run method loops ten times reading a value from buffer.
class Consumer implements Runnable
{
private final static Random generator = new Random();
private final Buffer sharedLocation; // reference to shared object
// constructor
public Consumer( Buffer shared )
{
sharedLocation = shared;
} // end Consumer constructor
// read sharedLocation's value 10 times and sum the values
public void run()
{
int sum = 0;
for ( int count = 1; count <= 10; count++ )
{
// sleep 0 to 3 seconds, read value from buffer and add to sum
try
{
Thread.sleep( generator.nextInt( 3000 ) );
sum += sharedLocation.get();
} // end try
// if lines 26 or 27 get interrupted, print stack trace
catch ( InterruptedException exception )
{
exception.printStackTrace();
} // end catch
} // end for
System.out.printf( "\n%s %d\n%s\n",
"Consumer read values totaling", sum, "Terminating Consumer" );
} // end method run
} // end class Consumer
class Producer implements Runnable
{
private final static Random generator = new Random();
private final Buffer sharedLocation; // reference to shared object
// constructor
public Producer( Buffer shared )
{
sharedLocation = shared;
} // end Producer constructor
// store values from 1 to 10 in sharedLocation
public void run()
{
int sum = 0;
for ( int count = 1; count <= 10; count++ )
{
try // sleep 0 to 3 seconds, then place value in Buffer
{
Thread.sleep( generator.nextInt( 3000 ) ); // sleep thread
sharedLocation.set( count ); // set value in buffer
sum += count; // increment sum of values
} // end try
// if lines 25 or 26 get interrupted, print stack trace
catch ( InterruptedException exception )
{
exception.printStackTrace();
} // end catch
} // end for
System.out.println(
"Producer done producing\nTerminating Producer" );
} // end method run
} // end class Producer
class CircularBuffer implements Buffer
{
private final int[] buffer = { -1, -1, -1 }; // shared buffer
private int occupiedCells = 0; // count number of buffers used
private int writeIndex = 0; // index of next element to write to
private int readIndex = 0; // index of next element to read
// place value into buffer
public void set( int value ) throws InterruptedException
{
// wait until buffer has space avaialble, then write value;
// while no empty locations, place thread in waiting state
while ( occupiedCells == buffer.length)
{
Thread.sleep(100);
} // end while
buffer[ writeIndex ] = value; // set new buffer value
// update circular write index
writeIndex = ( writeIndex + 1 ) % buffer.length;
++occupiedCells; // one more buffer cell is full
displayState( "Producer writes " + value );
// notifyAll(); // notify threads waiting to read from buffer
} // end method set
// return value from buffer
public int get() throws InterruptedException
{
// wait until buffer has data, then read value;
// while no data to read, place thread in waiting state
while (occupiedCells == 0 )
{
**Thread.sleep(100);**
} // end while
int readValue = buffer[ readIndex ]; // read value from buffer
// update circular read index
readIndex = ( readIndex + 1 ) % buffer.length;
--occupiedCells; // one fewer buffer cells are occupied
displayState( "Consumer reads " + readValue );
// notifyAll(); // notify threads waiting to write to buffer
return readValue;
} // end method get
// display current operation and buffer state
public void displayState( String operation )
{
// output operation and number of occupied buffer cells
System.out.printf( "%s%s%d)\n%s", operation,
" (buffer cells occupied: ", occupiedCells, "buffer cells: " );
for ( int value : buffer )
System.out.printf( " %2d ", value ); // output values in buffer
System.out.print( "\n " );
for ( int i = 0; i < buffer.length; i++ )
System.out.print( "---- " );
System.out.print( "\n " );
for ( int i = 0; i < buffer.length; i++ )
{
if ( i == writeIndex && i == readIndex )
System.out.print( " WR" ); // both write and read index
else if ( i == writeIndex )
System.out.print( " W " ); // just write index
else if ( i == readIndex )
System.out.print( " R " ); // just read index
else
System.out.print( " " ); // neither index
} // end for
System.out.println( "\n" );
} // end method displayState
}
我的问题不是如何正确地做到这一点,而是
最佳答案
Thread.sleep
用于减少不必要的 CPU 使用。在单核系统上,不 hibernate 可能会导致其他线程缺乏 CPU 时间,因此可能需要很长时间才能摆脱自旋锁。无论如何,look into using wait()
and notify()
而不是实现你自己的自旋锁。
关于java - 空 while 循环的线程问题,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/17457717/
我是 PHP 新手。我一直在脚本中使用 for 循环、while 循环、foreach 循环。我想知道 哪个性能更好? 选择循环的标准是什么? 当我们在另一个循环中循环时应该使用哪个? 我一直想知道要
我在高中的编程课上,我的作业是制作一个基本的小计和顶级计算器,但我在一家餐馆工作,所以制作一个只能让你在一种食物中读到。因此,我尝试让它能够接收多种食品并将它们添加到一个价格变量中。抱歉,如果某些代码
这是我正在学习的一本教科书。 var ingredients = ["eggs", "milk", "flour", "sugar", "baking soda", "baking powder",
我正在从字符串中提取数字并将其传递给函数。我想给它加 1,然后返回字符串,同时保留前导零。我可以使用 while 循环来完成此操作,但不能使用 for 循环。 for 循环只是跳过零。 var add
编辑:我已经在程序的输出中进行了编辑。 该程序要求估计给定值 mu。用户给出一个值 mu,同时还提供了四个不等于 1 的不同数字(称为 w、x、y、z)。然后,程序尝试使用 de Jaeger 公式找
我正在编写一个算法,该算法对一个整数数组从末尾到开头执行一个大循环,其中包含一个 if 条件。第一次条件为假时,循环可以终止。 因此,对于 for 循环,如果条件为假,它会继续迭代并进行简单的变量更改
现在我已经习惯了在内存非常有限的情况下进行编程,但我没有答案的一个问题是:哪个内存效率更高;- for(;;) 或 while() ?还是它们可以平等互换?如果有的话,还要对效率问题发表评论! 最佳答
这个问题已经有答案了: How do I compare strings in Java? (23 个回答) 已关闭 8 年前。 我正在尝试创建一个小程序,我可以在其中读取该程序的单词。如果单词有 6
这个问题在这里已经有了答案: python : list index out of range error while iteratively popping elements (12 个答案) 关
我正在尝试向用户请求 4 到 10 之间的整数。如果他们回答超出该范围,它将进入循环。当用户第一次正确输入数字时,它不会中断并继续执行 else 语句。如果用户在 else 语句中正确输入数字,它将正
我尝试创建一个带有嵌套 foreach 循环的列表。第一个循环是循环一些数字,第二个循环是循环日期。我想给一个日期写一个数字。所以还有另一个功能来检查它。但结果是数字多次写入日期。 Out 是这样的:
我想要做的事情是使用循环创建一个数组,然后在另一个类中调用该数组,这不会做,也可能永远不会做。解决这个问题最好的方法是什么?我已经寻找了所有解决方案,但它们无法编译。感谢您的帮助。 import ja
我尝试创建一个带有嵌套 foreach 循环的列表。第一个循环是循环一些数字,第二个循环是循环日期。我想给一个日期写一个数字。所以还有另一个功能来检查它。但结果是数字多次写入日期。 Out 是这样的:
我正在模拟一家快餐店三个多小时。这三个小时分为 18 个间隔,每个间隔 600 秒。每个间隔都会输出有关这 600 秒内发生的情况的统计信息。 我原来的结构是这样的: int i; for (i=0;
这个问题已经有答案了: IE8 for...in enumerator (3 个回答) How do I check if an object has a specific property in J
哪个对性能更好?这可能与其他编程语言不一致,所以如果它们不同,或者如果你能用你对特定语言的知识回答我的问题,请解释。 我将使用 c++ 作为示例,但我想知道它在 java、c 或任何其他主流语言中的工
这个问题不太可能帮助任何 future 的访问者;它只与一个小的地理区域、一个特定的时间点或一个非常狭窄的情况有关,这些情况并不普遍适用于互联网的全局受众。为了帮助使这个问题更广泛地适用,visit
我是 C 编程和编写代码的新手,以确定 M 测试用例的质因数分解。如果我一次只扫描一次,该功能本身就可以工作,但是当我尝试执行 M 次时却惨遭失败。 我不知道为什么 scanf() 循环有问题。 in
这个问题已经有答案了: JavaScript by reference vs. by value [duplicate] (4 个回答) 已关闭 3 年前。 我在使用 TSlint 时遇到问题,并且理
我尝试在下面的代码中添加 foreach 或 for 循环,以便为 Charts.js 创建多个数据集。这将允许我在此折线图上创建多条线。 我有一个 PHP 对象,我可以对其进行编码以稍后填充变量,但
我是一名优秀的程序员,十分优秀!