5

我想用Java模拟TCP。

为此,我有多个线程,例如每个 TCP 连接的发送者和接收者线程。

我的问题是,我想暂停(如 Thread.sleep())线程微秒时间间隔。这样我就可以模拟流控制,发送者线程在发送下一个数据包之前会阻塞几微秒,同时CPU可以被接收和数据处理线程使用。但我找不到任何执行 sleep() 或 wait() 以实现微秒或纳秒分辨率的方法。如何以微秒或纳秒的分辨率阻止(暂停)Java 中的线程?

我找到了 System.nanoTime() 方法,但是没有在指定的微秒或纳秒内阻塞线程的方法。如果有这样的方法,请告诉我。System.nanoTime() 仅给出以纳秒为单位的相对时间间隔。

我可以使用 System.nanoTime() 在使用忙循环的线程中执行纳秒延迟,但这会浪费 CPU,这本来可以用于接收数据线程或处理线程。

另一个令人困惑的问题:

通过上网,我发现 Thread.sleep() 或 wait() 方法在 Windows 系统中阻塞至少指定的毫秒或 10 毫秒的倍数,以较小者为准,没有线程中断。但是当我运行示例示例时,我发现了非常不同的结果。就像线程的睡眠时间少于指定的毫秒数。有些线程给了我 100 微秒的睡眠时间。测量的时间是否有误?System.nanoTime() 不是那么准确吗?请参见下面的示例,其中我得到了非常不同的结果。线程优先级也没有给出预测的结果。

public class MyClass {
    public static void main(String args []){
        Runnable r = new Runnable() {
            public void run() {
                long s = System.nanoTime();
                //Thread.yield();  // Try for yield, need to check - in how much time high priority thread will be scheduled back after yielding
                try{
                    Thread.sleep(1);
                }catch(Exception e){

                }
                long e = System.nanoTime() - s;
                System.out.println(Thread.currentThread().getName()+e);
            }
        };

        Thread t1 = new Thread(r, "Thread T1: ");
        t1.setPriority(Thread.MAX_PRIORITY);
        t1.start();

        Thread t2 = new Thread(r, "Thread T2: ");
        t2.setPriority(Thread.MIN_PRIORITY);
        t2.start();

        Thread t3 = new Thread(r, "Thread T3: ");
        t3.setPriority(Thread.NORM_PRIORITY);
        t3.start();

        Thread t4 = new Thread(r, "Thread T4: ");
        t4.setPriority(Thread.MAX_PRIORITY);
        t4.start();

        long s = System.nanoTime();
        try{
            Thread.sleep(1);
        }catch(Exception e){

        }
        long e = System.nanoTime() - s;
        System.out.println("Main: "+e);
    }
}

在我的带有 Intel Core i5、2.53 GHz 的系统中,我在多次运行中得到类似下面的输出。*这篇文章中没有打印下面输出中的换行符,我已经从控制台复制了输出,但是它在我的控制台中给了我换行符,这没问题。

线程 T1:736682 线程 T3:700212 线程 T2:478559 主线程:548257 线程 T4:458299

第二轮——

线程 T3:27555 线程 T2:139799 线程 T1:152361 主线程:93199 线程 T4:29986

第三轮——

线程 T4:724525 线程 T2:1050319 主线程:752486 线程 T1:941316 线程 T3:1000883

第四轮——

线程 T1:174243 线程 T2:166543 线程 T3:1005745 主线程:1023170 线程 T4:915787

在上面的运行中,我得到了微秒阻塞。:O

请指导我。

为长文道歉。感谢您阅读整篇文章。

4

4 回答 4

4

请注意,Thread.sleep(timeout)保证将至少Thread休眠超时 ms(取决于底层系统的精度),但它可能会休眠更长时间。

Thread.sleep(millis, nanos),但精度也不是很好。正如@TimBender 在下面指出的那样,在 OpenJDK 6-b14 中,它甚至通过舍入和调用来实现这一点Thread.sleep(millis)。因此,可以相当肯定地说,在任何 Java 实现中,您都不能依赖它在确切的时间间隔内休眠。

于 2012-10-29T20:58:53.007 回答
3

您受操作系统线程调度程序的支配,对此您无能为力。仅仅因为你睡了很短的时间并不意味着调度程序会在它完成睡眠后立即唤醒你的线程。而线程优先级只是一个提示,没有任何保证。

于 2012-10-29T21:01:28.017 回答
0

试试这个:

Thread.sleep(0, 250); // sleep 250 nanoseconds
于 2012-10-29T21:02:42.210 回答
0

我相信您要使用的是Condition.awaitNanos,但是我找不到任何确凿的证据来证明这将在接近请求的时间时以高精度返回。

或者,您可以传递一个略小于所需总时间的“awaitNanos”时间,然后在循环中“实时等待”,直到总时间过去。

于 2012-10-29T21:10:57.310 回答