IEnumerator YieldMeSomeStuff() { yield "hello"; Console.WriteLine("foo!"); yield "world"; } IEnumerator e = YieldMeSomeStuff(); while(e.MoveNext()) { Console.WriteLine(e.Current); } hello foo! world... Õ¹¿ªÏêÇë

ÄúÓ¦¸ÃʹÓÃ-documentation£º % ocamlbuild -documentation | grep thread flag {. byte, link, ocaml, program, thread .} "threads.cma -thread" flag {. link, native, ocaml, program, thread .} "threads.cmxa -thread" flag {. doc, ocaml, thread .} "-I +threads" flag {. compile, ocaml, thread .} "-thread" -tag threadµ½ocamlbuildµ÷ÓÃÐУ¬»òÕßÖ»ÊÇthread¡£... Õ¹¿ªÏêÇë

ʹÓÃMethodInvoker¸üÐÂÆäËûÏß³ÌÖеıêÇ©Îı¾£º private void AggiornaContatore() { MethodInvoker inv = delegate { this.lblCounter.Text = this.index.ToString(); } this.Invoke(inv); }... Õ¹¿ªÏêÇë

ͨ³£Çé¿öÏ£¬ÎÒʹÓÃN + 1¸öỊ̈߳ºÒ»¸öÓÃÓÚServerSocket£¬±ÜÃâ×èÈûÕû¸öÓ¦ÓóÌÐòµÈ´ý¿Í»§¶ËÁ¬½Ó; ºÍN¸öÏß³ÌÀ´´¦Àí¿Í»§¶ËµÄÇëÇó£¬NÊÇÏ̳߳صĴóС£¨ÎÒ½¨ÒéʹÓÃÏ̳߳ØÀ´ÎªÃ¿¸ö¿Í»§¶Ë´´½¨Ò»¸öÐÂỊ̈߳©¡£ public class Server { public static void main(String[] args) { new Server().startServer(); } public void startServer() { final ExecutorService clientProcessingPool = Executors.newFixedThreadPool(10); Runnable serverTask = new Runnable() { @Override public void run() { try { ServerSocket serverSocket = new ServerSocket(8000); System.out.println("Waiting for clients to connect..."); while (true) { Socket clientSocket = serverSocket.accept(); clientProcessingPool.submit(new ClientTask(clientSocket)); } } catch (IOException e) { System.err.println("Unable to process client request"); e.printStackTrace(); } } }; Thread serverThread = new Thread(serverTask); serverThread.start(); } private class ClientTask implements Runnable { private final Socket clientSocket; private ClientTask(Socket clientSocket) { this.clientSocket = clientSocket; } @Override public void run() { System.out.println("Got a client !"); // Do whatever required to process the client's request try { clientSocket.close(); } catch (IOException e) { e.printStackTrace(); } } } } ... Õ¹¿ªÏêÇë