您好,匿名用户

{求解答}一个有关互斥锁的问题

0 投票

我想要实现这么一个功能:
程序中有一个数组0~15,一共16个帧序号用来标识下发的报文。报文下发时,需要给它一个帧序号;如果下发的报文被客户端接收并返回,需要重新回收该报文的帧序号。
为了避免在给多个报文分配帧序号时出现重复帧序号的情况,我在分配帧序号的方法里用了个互斥锁,锁住了一个用来管理闲置的帧序号的变量,但同时,这又出现了另外一个问题,下面我放上代码,问题写在OfferFrameNo()里的注释上:

public class FrameNumberController {
    private static int MAX_FRAME_NO = 16;
    static Map<Integer,byte[]> frame_info = new HashMap<Integer, byte[]>();//存储还在处理的frame的信息
    static List<Integer> available_no = new ArrayList<Integer>();//闲置的帧序号
    
    static void init(){
        for (int i = 0; i < MAX_FRAME_NO; i++){
            available_no.add(i);
        }
    }
    
    public static void RecordFrame(int frame_no, byte[] output){
        frame_info.put(frame_no, output);
    }
    
    public static void RecallFrameNo(int frame_no){
        frame_info.remove(frame_no);
        available_no.add(frame_no);
    }
    
    public static int OfferFrameNo(){
        int frame_no = 0;
        int available_no_size=0;
        /*
         * 避免同时获取同一个frame_no
         * 添加互斥锁
         */
        //******互斥锁开始*****
        synchronized(available_no){
            /*Q:有问题,如果available_no已经没有可用号码了,当RecallFrameNo要召回frame_no,
            但是因为这里的互斥锁而没有召回成功的话,就会变成死循环了,肿么办?*/
            while(available_no_size <= 0){
                available_no_size = available_no.size();
            }
            frame_no = available_no.get(0);
            available_no.remove(0);
        }
        //******互斥锁结束*****
        
        return frame_no;
        
    }
}

我有想过把判断是否有闲置帧序号的循环放到互斥锁外面,像这样:

            while(available_no_size <= 0){
                available_no_size = available_no.size();
            }
            synchronized(available_no){
                frame_no = available_no.get(0);
                available_no.remove(0);
            }

但又可能出现另一个问题。万一,某个线程在进入互斥锁的前一瞬间available_no_size不等于0,后一瞬间就被另外一个线程获取了这个唯一闲置的帧序号呢?这种情况会不会有可能发生?
第一次用互斥锁,可能也没有搞清楚它的用法,请各位提供一下思路,谢谢。

————————————EDIT————————————
又或者把available_no_size也加一个互斥锁?这样会不会显着很累赘?

            synchronized(available_no_size){
                while(available_no_size <= 0){
                    available_no_size = available_no.size();
                }
            }
            synchronized(available_no){
                frame_no = available_no.get(0);
                available_no.remove(0);
            }
用户头像 提问 2017年 6月19日 @ Sejuani 中士 (1,102 威望)
分享到:

1个回答

0 投票

使用BlockingQueue呀,简单易懂

用户头像 回复 2017年 6月19日 @ Scorpio 中士 (1,060 威望)
提一个问题:

相关问题

0 投票
1 回复 36 阅读
用户头像 提问 2017年 5月3日 @ Rumble 中士 (1,184 威望)
0 投票
1 回复 53 阅读
0 投票
1 回复 34 阅读
用户头像 提问 2017年 5月18日 @ Tashigi 下士 (836 威望)
0 投票
1 回复 27 阅读
0 投票
1 回复 15 阅读
用户头像 提问 2017年 3月17日 @ Aatrox 中士 (1,083 威望)

欢迎来到随意问技术百科, 这是一个面向专业开发者的IT问答网站,提供途径助开发者查找IT技术方案,解决程序bug和网站运维难题等。
温馨提示:本网站禁止用户发布与IT技术无关的、粗浅的、毫无意义的或者违法国家法规的等不合理内容,谢谢支持。

欢迎访问随意问技术百科,为了给您提供更好的服务,请及时反馈您的意见。
...