Java/DataStructures/Buffers/CircularBuffer.java at master · AadityaGupta/Java · GitHub

History

132 lines (107 loc) · 3.65 KB

Raw

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

package DataStructures.Buffers;

import java.util.Random;

import java.util.concurrent.atomic.AtomicInteger;

public class CircularBuffer {

private char[] _buffer;

public final int _buffer_size;

private int _write_index = 0;

private int _read_index = 0;

private AtomicInteger _readable_data = new AtomicInteger(0);

public CircularBuffer(int buffer_size) {

if (!IsPowerOfTwo(buffer_size)) {

throw new IllegalArgumentException();

}

this._buffer_size = buffer_size;

_buffer = new char[buffer_size];

}

private boolean IsPowerOfTwo(int i) {

return (i & (i - 1)) == 0;

}

private int getTrueIndex(int i) {

return i % _buffer_size;

}

public Character readOutChar() {

Character result = null;

//if we have data to read

if (_readable_data.get() > 0) {

result = Character.valueOf(_buffer[getTrueIndex(_read_index)]);

_readable_data.decrementAndGet();

_read_index++;

}

return result;

}

public boolean writeToCharBuffer(char c) {

boolean result = false;

//if we can write to the buffer

if (_readable_data.get() < _buffer_size) {

//write to buffer

_buffer[getTrueIndex(_write_index)] = c;

_readable_data.incrementAndGet();

_write_index++;

result = true;

}

return result;

}

private static class TestWriteWorker implements Runnable {

String _alphabet = "abcdefghijklmnopqrstuvwxyz0123456789";

Random _random = new Random();

CircularBuffer _buffer;

public TestWriteWorker(CircularBuffer cb) {

this._buffer = cb;

}

private char getRandomChar() {

return _alphabet.charAt(_random.nextInt(_alphabet.length()));

}

public void run() {

while (!Thread.interrupted()) {

if (!_buffer.writeToCharBuffer(getRandomChar())) {

Thread.yield();

try {

Thread.sleep(10);

} catch (InterruptedException e) {

return;

}

private static class TestReadWorker implements Runnable {

CircularBuffer _buffer;

public TestReadWorker(CircularBuffer cb) {

this._buffer = cb;

}

@Override

public void run() {

System.out.println("Printing Buffer:");

while (!Thread.interrupted()) {

Character c = _buffer.readOutChar();

if (c != null) {

System.out.print(c.charValue());

} else {

Thread.yield();

try {

Thread.sleep(10);

} catch (InterruptedException e) {

System.out.println();

return;

}

public static void main(String[] args) throws InterruptedException {

int buffer_size = 1024;

//create circular buffer

CircularBuffer cb = new CircularBuffer(buffer_size);

//create threads that read and write the buffer.

Thread write_thread = new Thread(new TestWriteWorker(cb));

Thread read_thread = new Thread(new TestReadWorker(cb));

read_thread.start();

write_thread.start();

//wait some amount of time

Thread.sleep(10000);

//interrupt threads and exit

write_thread.interrupt();

read_thread.interrupt();

}

Java/DataStructures/Buffers/CircularBuffer.java at master · AadityaGupta/Java · GitHub

Expand file tree

Breadcrumbs

CircularBuffer.java

Latest commit

History

Breadcrumbs

CircularBuffer.java

File metadata and controls