Hi,

I can't seem to find working  directions for running green threads with
java. I have a sample program which should run one thread with higher
priority than another, but it doesn't seem to work that way when I run
it. Any clues?

My goal is to prioritize one thread over another. I downloaded and
installed blackdown, compiled the code and ran it. it doesn't seem to
work

When I try running blackdown with '-green', I get an error:

Error: green VM not supported

When I run by setting THREADS_FLAG=green, the priorities don't work:

10
MAX_PRIORITY=10
MIN_PRIORITY=1
NORM_PRIORITY=5
Starting thread B0
priority=10
Starting thread A0
priority=1
---

I do an 'ls' on the output files. If one thread runs with higher
priority than another, then, file outB should be much larger than outA,
but this is not the case:

-rw-rw-r--  1 dtliu dtliu 188510 Dec  9 01:33 outB
-rw-rw-r--  1 dtliu dtliu 186572 Dec  9 01:33 outA

---

Here is the program, just in case I'm doing something wrong:

import java.io.*;
import java.util.*;

class TestThreads{

public static void main(String []args){
int numA = Integer.parseInt(args[0]);
int numB = Integer.parseInt(args[1]);
int priorityA = Integer.parseInt(args[2]);
int priorityB = Integer.parseInt(args[3]);

System.out.println("MAX_PRIORITY=" + Thread.MAX_PRIORITY );
System.out.println("MIN_PRIORITY=" + Thread.MIN_PRIORITY );
System.out.println("NORM_PRIORITY=" + Thread.NORM_PRIORITY );

try{
PrintWriter pwA = new PrintWriter(new FileWriter("outA"));
PrintWriter pwB = new PrintWriter(new FileWriter("outB"));

createThreads(numB, priorityB, "B",pwB);
createThreads(numA, priorityA, "A",pwA);

}catch(Exception E){
System.out.println("Problem");
System.exit(1);
}

} //main

public static void createThreads(int numThreads, int priority, String
prefix, PrintWriter pw){
for(int i=0; i<numThreads; i++){
String name = prefix + i;
System.out.println("Starting thread " + name);
Thread t = new Thread(new ThreadA(pw, name));
t.setPriority(priority);
System.out.println("priority=" + t.getPriority());
t.start();
//   System.out.println("Afterwards"); //ddd
} //for
} //createThreads

} //TestThreads

class ThreadA implements Runnable{

ThreadA(PrintWriter bw, String threadClass){
this.bw = bw;
this.threadClass = threadClass;
}

private String threadClass = null;
private PrintWriter bw = null;
private int counter = 0;

public void run(){
while(true){
// try{ Thread.sleep(100); }catch(Exception e){
System.out.println("thread " + threadClass + " interrupted."); }
for(int i=0; i<100000; i++){
int x = 2 / (i + 1);
} //for

Date d = new Date(System.currentTimeMillis());
bw.println(threadClass + " " + counter++ + ": " + d);
bw.flush();
 
 } //while
} //run

} //ThreadA