线程初步
import java.net.*;import java.io.*; public class RunnableDemo { public static void main(String args[]) { ServerSocket s = null; Socket s1;String sendString = "Hello Net World!"; OutputStream s1out; DataOutputStream dos; try { s = new ServerSocket(5432); } catch (IOException e) { } while (true) { try { s1=s.accept(); s1out = s1.getOutputStream(); dos = new DataOutputStream (s1out);dos.writeUTF(sendString); s1out.close(); s1.close(); } catch (IOException e) { } } } }class PrintThread extends Thread{private int sleepTime;public PrintThread(String name){super(name);sleepTime=(int)(Math.random()*5000);System.err.println("Name:"+getName()+"; sleep:"+sleepTime);}public void run(){ try { System.err.println(getName()+"going to sleep"); Thread.sleep(sleepTime); } catch(InterruptedException e) { System.err.println(e.toString()); }System.err.println(getName()+" done sleeping");}}
public class ThreadTester {public static void main(String[] args){PrintThread thread1,thread2,thread3,thread4;thread1=new PrintThread("thread1");thread2=new PrintThread("thread2");thread3=new PrintThread("thread3");thread4=new PrintThread("thread4");System.err.println("\nStarting threads");thread1.start();thread2.start();thread3.start();thread4.start();System.err.println("Thread started\n");}}
页:
[1]