updates: I think/ suspect the imageIO is not thread safe. shared by all threads. the read() call might use resources that are also shared. Thus it will give the performance
of a single thread no matter how many threads used. ? if its correct . what is the solution (in practical code)
Single request and response model at one time do not utilizes full network/internet bandwidth, thus resulting in low performance. (benchmark is
of half speed utilization or even lower)
This is to make a video
out of an IP cam that gives a new image on each request.
http://149.5.43.10:8001/snapshot.jpg
It makes a delay
of 3 - 8 seconds no matter what I do.
Changed thread no. and thread time intervals, debugged the code by System.
out.println statements to see if threads work. All seems normal. Any help?
Please show some practical code. You may modify mine.
This code works (javascript) with much smoother frame rate and max bandwidth usage. but the later code (java) dont. same 3 to 8 seconds gap.
<!DOCTYPE html>
<html>
<head>
<script type="text/javascript">
(function(){
var img="/*url*/";
var interval=50;
var pointer=0;
function showImg(image,idx)
{
if(idx<=pointer) return;
document.body.replaceChild(image,document.getElementsByTagName("img")[0]);
pointer=idx;
preload();
}
function preload()
{
var cache=null,idx=0;;
for(var i=0;i<5;i++)
{
idx=Date.now()+interval*(i+1);
cache=new Image();
cache.onload=(function(ele,idx){return function(){showImg(ele,idx);};})(cache,idx);
cache.src=img+"?"+idx;
}
}
window.onload=function(){
document.getElementsByTagName("img")[0].onload=preload;
document.getElementsByTagName("img")[0].src="/*initial url*/";
};
})();
</script>
</head>
<body>
<img />
</body>
</html>
and
of java (with problem) :
package camba;
import java.applet.Applet;
import java.awt.Button;
import java.awt.Graphics;
import java.awt.Image;
import java.awt.Label;
import java.awt.Panel;
import java.awt.TextField;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.net.URL;
import java.security.Timestamp;
import java.util.Date;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;
import javax.imageio.ImageIO;
public class Camba extends Applet implements ActionListener{
Image img;
TextField textField;
Label label;
Button start,stop;
boolean terminate = false;
long viewTime;
public
void init(){
label = new Label("please enter camera URL ");
add(label);
textField = new TextField(30);
add(textField);
start = new Button("Start");
add(start);
start.addActionListener(this);
stop = new Button("Stop");
add(stop);
stop.addActionListener(this);
}
public
void actionPerformed(ActionEvent e){
Button source = (Button)e.getSource();
if(source.getLabel() == "Start"){
for (int i = 0; i < 7; i++) {
myThread(50*i);
}
System.
out.println("start...");
}
if(source.getLabel() == "Stop"){
terminate = true;
System.
out.println("stop...");
}
}
public
void paint(Graphics g) {
update(g);
}
public
void update(Graphics g){
try{
viewTime = System.currentTimeMillis();
g.drawImage(img, 100, 100, this);
} catch(Exception e) {
e.printStackTrace();
}
}
public
void myThread(final int sleepTime){
new Thread(new Runnable() {
public
void run() {
while(!terminate){
try {
TimeUnit.MILLISECONDS.sleep(sleepTime);
} catch (InterruptedException ex) {
ex.printStackTrace();
}
long requestTime= 0;
Image tempImage = null;
try {
URL pic = null;
requestTime= System.currentTimeMillis();
pic = new URL(getDocumentBase(), textField.getText());
tempImage = ImageIO.read(pic);
} catch(Exception e) {
e.printStackTrace();
}
if(requestTime >= /*last view time*/viewTime){
img = tempImage;
Camba.this.repaint();
}
}
}}).start();
System.
out.println("thread started...");
}
}
